在高可用集群上搭建kafka并使用

解压文件后

1.修改server.properties中的

broker.id=0
log.dirs=/opt/install/kafka/kafka-logs
zookeeper.connect=nodethree:2181,nodefour:2181,nodefive:2181      

2.分发到各个节点,修改broker.id=0

3.编写启动脚本

在Kafka目录下

vim start-kafka.sh      

编写脚本

#bin/bash
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &      

如下

4启动脚本

bin/kafka-topics.sh --zookeeper nodethree:2181,nodefour:2181,nodefive:2181 --list

bin/kafka-topics.sh --zookeeper nodethree:2181,nodefour:2181,nodefive:2181 --create --topic 20210120 --partitions 3 -replication-factor 3

bin/kafka-topics.sh --zookeeper nodethree:2181,nodefour:2181,nodefive:2181 --describe --topic 20210120


bin/kafka-console-producer.sh --broker-list nodethree:9092,nodefour:9092,nodefive:9092 --topic 20210120


bin/kafka-console-consumer.sh --zookeeper nodethree:2181,nodefour:2181,nodefive:2181 --topic 20210120 --from-beginning