kafka集群安装

1.准备三台机器，手动下载kafka安装包
2.解压移动
3.配置jdk+环境变量
4.配置Kafka

kafka/config/server.properties
broker.id=XXX 唯一
log.dir=指定目录
zookeeper.connet=ip:2181,...

5.分发文件

scp -r kafka root@ip1:/....1

scp -r kafka root@ip2:/....2

6.先启动zk 再启动kafka-server-start.sh
bin/kafka-server-start.sh -daemon config/server.properties
7.验证kafka是否启动
netstart -anop | grep 9092
8.创建主题
bin/kafka-topics.sh --create --zookeeper ip:2181 --replication-factor 1 --topic test
9.查看主题列表
bin/kafka-topics.sh --list --zookeeper c1:2181
10.启动控制台生产者
bin/kafka-console-producer.sh --broker-list ip:9092 --topic test
11.启动控制台消费者(另一台主机)
bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic test --from-beginning