当前位置: 首页>后端>正文

kafka 单机安装

从kafka官网上下载kafka的二进制安装包,下载地址是:https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz,下载下来之后进行解压。

wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz

kafka 单机安装,第1张

接着对文件进行解压。

????????sudo tar -zvxf kafka_2.12-2.4.0.tgz -C? /opt/

kafka 单机安装,第2张

提取文件成功之后,接着创建一个文件的软连接,这样可以方便进行kafka的升级。

????????sudo ln -s /opt/kafka_2.12-2.4.0 /opt/kafka

kafka 单机安装,第3张
kafka 单机安装,第4张

接下来,进入到kafka目录下,启动kafka,启动kafka之前得先启动zookeeper。

????????????sudo ./zookeeper-server-start.sh ../config/zookeeper.properties

kafka 单机安装,第5张

接着在开启一个shell进行启动kafka。

????????????sudo ./kafka-server-start.sh ../config/server.properties

kafka 单机安装,第6张

由于通过上面的方式启动不是很方便,接下来就配置系统单元服务进行启动kafka和zookeeper。

按照以下方式创建zookeeper.service系统服务单元。

[root@localhost ~]$sudo? vi /etc/systemd/system/zookeeper.service

[Unit]

Description=Apache Zookeeper server

Documentation=http://zookeeper.apache.org

Requires=network.target remote-fs.target

After=network.target remote-fs.target

[Service]

Type=simple

ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties

ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh

Restart=on-abnormal

User=root

Group=root

[Install]

WantedBy=multi-user.target

kafka 单机安装,第7张

保存完成之后,来启动验证一下是否配置成功。

????????systemctl start zookeeper

????????systemctl status zookeeper

????????systemctl start zookeeper

kafka 单机安装,第8张

接着在配置一下kafka服务器的系统服务单元。

[root@localhost ~]$ sudo vi /etc/systemd/system/kafka.service

[Unit]

Description=Apache Kafka Server

Documentation=http://kafka.apache.org/documentation.html

Requires=zookeeper.service

[Service]

Type=simple

ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties

ExecStop=/opt/kafka/bin/kafka-server-stop.sh

Restart=on-abnormal

[Install]

WantedBy=multi-user.target

kafka 单机安装,第9张

配置完成之后,接着来启动kafka。

? ? ? ? systemctl start kafka

? ? ? ? systemctl status kafka

? ? ? ? systemctl stop kafka

kafka 单机安装,第10张

创建成功之后,接下来,测试一下是否安装成功。

测试之前先通过kafka创建一个topic。进入到kafka目录下,接着通过下面命令创建一个kafka topic。

????????????bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testTopic

kafka 单机安装,第11张

查看创建了多少个topic,可以使用以下命令进行查看。

????????????????bin/kafka-topics.sh --list --zookeeper localhost:2181

kafka 单机安装,第12张

接下来通过生产者进行发送消息。

????????????bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic

接着创建一个消费者来进行接收消息。

????????????bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning

kafka 单机安装,第13张

通过以上步骤,就成功安装kafka了,这个时候就可以通过java开发工具连接进行开发了。


https://www.xamrdz.com/backend/37j1927425.html

相关文章: