kafka消費之kafka查看topic是否有數據

通過原生kafka，查看對應的topic是否有數據

• 下載kafka：登錄Apache kafka官方下載 http://kafka.apache.org/downloads.html
• 配置config文件 vim server.properties
• 啟動kafka：

./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &     # kafka-server-start.sh 腳本在 kafka_2.12-2.2.0/bin路徑下

• 查看已創建的topic列表：

 ./kafka-topics.sh --list --zookeeper localhost:2181

• 查看對應topic的描述信息： 

./kafka-topics.sh --describe --zookeeper xx.x.xxx.xxx:2181 --topic xxxxx.xx.xxxxx.xxx     # --zookeeper為zookeeperIP, --topic為topic名稱 

• 消費消息：

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic xxxxx.xx.xxxxx.xxx --from-beginning    # 若沒有任何返回或沒有響應，則該topic中沒有數據內容；否則有

 

 

參考鏈接： https://blog.csdn.net/panchang199266/article/details/82113453