kafka的bin目錄下有很多腳本，其中kafka-console-producer.sh是生產(chǎn)者腳本、kafka-console-consumer.sh是消費(fèi)者腳本，下面用這兩個(gè)腳本進(jìn)行模擬發(fā)送消息和接收消息。在前面的3篇中已經(jīng)介紹了kafka的配置。按照步驟啟動(dòng)zookeeper和kafka。

　　1、創(chuàng)建topic

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

　　2、發(fā)送消息

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

　　說(shuō)明： --broker-list：指定發(fā)送到哪個(gè)broker上面，如果指定多個(gè)broker用逗號(hào)隔開。

　　 --topic：指定broker上面的哪個(gè)topic接收發(fā)送的消息。

　　3、接收消息

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

　　說(shuō)明：--zookeeper：指定zookeeper的地址

　　 --topic：指定接收哪個(gè)topic中的消息

　　4、運(yùn)行結(jié)果如圖，一個(gè)生產(chǎn)者窗口發(fā)送消息，兩個(gè)消費(fèi)者窗口都能接收到：

生產(chǎn)者窗口

消費(fèi)者窗口1

消費(fèi)者窗口2

　　備注：這里的使用了一臺(tái)服務(wù)器，集群的情況后續(xù)研究

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。