kafka的bin目錄下有很多腳本，其中kafka-console-producer.sh是生產者腳本、kafka-console-consumer.sh是消費者腳本，下面用這兩個腳本進行模擬發送消息和接收消息。在前面的3篇中已經介紹了kafka的配置。按照步驟啟動zookeeper和kafka。

　　1、創建topic

bin/kafka-topics.sh --create --zookeeper 192.168.7.151:2181 --replication-factor 1 --partitions 3 --topic mydemo1

　　2、發送消息

bin/kafka-console-producer.sh --broker-list 192.168.7.151:9092 --topic mydemo1

　　說明： --broker-list：指定發送到哪個broker上面，如果指定多個broker用逗號隔開。

　　 --topic：指定broker上面的哪個topic接收發送的消息。

　　3、接收消息

bin/kafka-console-consumer.sh --zookeeper 192.168.7.151:2181 --topic mydemo1

　　說明：--zookeeper：指定zookeeper的地址

　　 --topic：指定接收哪個topic中的消息

　　4、運行結果如圖，一個生產者窗口發送消息，兩個消費者窗口都能接收到：

生產者窗口

消費者窗口1

消費者窗口2

　　備注：這里的使用了一臺服務器，集群的情況后續研究

總結

以上是生活随笔為你收集整理的（05）使用kafka脚本发送消息和接收消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。