安裝kafka

tar -zxvf kafka_2.11-2.2.0.tgz

編輯kafka啟動配置檔案

vim /conf/server.properties

# 配置如下內容

broker.id=1
listeners = PLAINTEXT://192.168.174.133:9092
advertised.listeners=PLAINTEXT://192.168.174.133:9092
zookeeper.connect=192.168.174.133:2181,192.168.174.134:2181

安裝kafka到一臺機器

修改配置

broker.id=1
listeners = PLAINTEXT://
 
192.168.174.134:9092
advertised.listeners=PLAINTEXT://192.168.174.134:9092
zookeeper.connect=192.168.174.133:2181,192.168.174.134:2181

在兩臺伺服器上分別啟動kafka服務

./kafka-server-start.sh -daemon ../config/server.properties

建立topic，隨意指定節點

./kafka-topics.sh --create --zookeeper 192.168.174.133:2181 --replication-factor 1
 
 --partitions 1 --topic test

向topic傳送訊息，隨意指定節點

./kafka-console-producer.sh --broker-list 192.168.174.133:9092 --topic test

在多個節點上分別消費 test

./kafka-console-consumer.sh --bootstrap-server 192.168.174.133:9092 --topic test --from-beginning
./kafka-console-consumer.sh --bootstrap-server 192.168.174.134:9092 --topic test --from-beginning

參考連結：https://blog.csdn.net/qq_25763595/article/details/107731706