1.修改每臺服務器config/server.properties
broker.id:唯一，填數(shù)字
host.name:填寫服務器IP
zookeeper.connect=192.168.1.100:2181,192.168.1.101:2181,192.168.1.103:2181
2.啟動
先啟動zookeeper服務
bin/zkServer.sh start
再在每臺機器上執(zhí)行Kafka服務
bin/kafka-server-start.sh config/server.properties
3.創(chuàng)建topic
bin/kafka-topics.sh —create —zookeeper localhost:2181 —replication-factor 3 —partitions 1 —topic demo_1
4.查看topic
bin/kafka-topics.sh —list —zookeeper localhost:2181
5.查看詳細信息
bin/kafka-topics.sh —describe —zookeeper 192.168.1.100:2181
6.發(fā)送消息
bin/kafka-console-producer.sh —broker-list 192.168.1.100:9092 —topic demo_1
7.接收消息
bin/kafka-console-consumer.sh —zookeeper 192.168.1.100:2181 —topic demo_1 —from-beginning