注意:低版本需要安装zookeeper,在2.8及以上可移除zookeeper
前往官网下载
!!!不要下载src文件
1.解压文件
tar xzf kafka_2.13-3.4.0.tgz
进入文件
cd kafka_2.13-3.4.0
进入
cd config/kraft
2.修改server.properties以下属性
vim server.properties
3.我们需要在启动服务器之前创建kafka集群id。执行下列命令,并记下运行生成的uuid:
./bin/kafka-storage.sh random-uuid
Z_aPqvh6SPyxIIHEo9Os8A
!!!只需要一个集群ID
4.接下来我们格式化所有存储目录:
#server1
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
#server2
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
#server3
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
5.可以使用以下命令在守护程序模式下启动kafka服务器
#server1
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
#server2
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
#server3
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
jps查看是否启动
6.使用以下命令创建hello-kraft topic:
./bin/kafka-topics.sh --create --topic hello-kraft --partitions 3 --replication-factor 3 --bootstrap-server 10.136.3.201:9091
7.生产和消费kafka数据
使用以下命令开启一个生产者
bin/kafka-console-producer.sh --broker-list 10.136.3.201:9091 --topic hello-kraft
在另一个终端中,使用以下命令启动消费者,注意,监听的集群另一个节点
bin/kafka-console-consumer.sh --bootstrap-server 10.136.3.202:9092 --topic hello-kraft
测试:生产者输入 成功
消费者消费
列出所有topic查看文章来源:https://www.toymoban.com/news/detail-436576.html
bin/kafka-topics.sh --list --bootstrap-server 10.136.3.201:9091文章来源地址https://www.toymoban.com/news/detail-436576.html
到了这里,关于kafka3.4.0集群搭建(无zookeeper)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!