這篇文章主要介紹kafka如何查詢topic列表和topic下的消息 ，文中介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們一定要看完！

目前創(chuàng)新互聯(lián)已為上千多家的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)絡(luò)空間、網(wǎng)站托管維護(hù)、企業(yè)網(wǎng)站設(shè)計、印臺網(wǎng)站維護(hù)等服務(wù)，公司將堅持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。

使用Kafka經(jīng)常碰到需要查看topic是否創(chuàng)建，或是查看topic下的數(shù)據(jù)。

最開始想直接找可視化工具進(jìn)行查看就找到了Kafka tool 然后發(fā)現(xiàn)鏈接數(shù)據(jù)較少的環(huán)境確實比較好用，但是如果topic或topic下的數(shù)據(jù)較多就會直接卡死，導(dǎo)致無法打開。

Kafka tool 的簡單使用

首先去官網(wǎng)下載 Kafka tool ：https://www.kafkatool.com/

無腦下一步進(jìn)行安裝。安裝完成后進(jìn)行新建鏈接操作

因為數(shù)據(jù)在Kafka都是byte所以要配置byte轉(zhuǎn)string才能更方便的查看

在 tools --> settings --> Topics

然后選中想要查看的topic在properties中配置key和message為string

然后進(jìn)入topic下的分區(qū)進(jìn)行查看，點擊綠色查詢按鈕即可查看

如果數(shù)據(jù)量較少可以使用這個工具進(jìn)行查看，但是數(shù)據(jù)太多回直接卡死

使用Kafka命令腳本查看

由于我們公司Kafka是部署在docker中所以需要先進(jìn)入Kafka容器，然后進(jìn)入opt/kafka/bin/目錄下，Kafka腳本命令都在這個目錄下

查看kafka topic列表

kafka-topics.sh -list --zookeeper zookeeper地址:端口

從頭開始查看kafka topic下的數(shù)據(jù)

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --from-beginning

按照偏移量查看topic下數(shù)據(jù)

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --offset latest --partition 0

# --offset設(shè)置偏移量 latest代表最后 ，可以設(shè)置區(qū)間，不設(shè)置結(jié)尾的話默認(rèn)為查詢到latest(最后)
# --partition 設(shè)置分區(qū) 使用偏移量查詢時一定要設(shè)置分區(qū)才能查詢

清除Kafka topic下所有消息

kafka-topics.sh --zookeeper zookeeper地址:端口 --delete --topic topic_name

以上是“kafka如何查詢topic列表和topic下的消息 ”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前文章：kafka如何查詢topic列表和topic下的消息
網(wǎng)頁鏈接：http://chinadenli.net/article30/ppccpo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設(shè)、關(guān)鍵詞優(yōu)化、微信公眾號、服務(wù)器托管、網(wǎng)站導(dǎo)航、品牌網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)