檢視kafka的topic清單以及topic的內容

2021-10-10 11:47:49 字數 619 閱讀 3344

對於雲端伺服器上執行著的kafka集群,由於沒有開放相關的埠,之前檢視都是使用埠**,ssh練上去之後,使用埠**,**到本地檢視。

使用kafka時發現,zk連線上之後,裡面的brokers其實是雲端伺服器的內網,但是kafka tools會直接認為那些ip是本地ip,就會看不到kafka裡面的內容。

試來試去,沒找到合適的方法解決。如果有誰知道怎麼弄,還請告訴我一聲,非常感謝~

檢視某個topic內容:kafka-console-consumer.sh --bootstrap-server [server]:9092 --from-beginning --topic [topicname]

kafka消費之kafka檢視topic是否有資料

配置config檔案為 server.properties 指令碼在 kafka bin路徑下 啟動kafka kafka server start.sh config server.properties 1 dev null 2 1 kafka server start.sh檢視已建立的topic...

kafka刪除topic的方法

0.8的官方文件提供了乙個刪除topic的命令 kafka topics.sh delete 但是在執行時會報錯找不到這個方法。kafka topics.sh最終是執行了kafka.admin.topiccommand這個類,在0.8的原始碼中這個類中沒有找到有delete topic相關的 在ka...

Kafka主題 topic 的刪除

step1 如果需要被刪除topic 此時正在被程式 produce和consume,則這些生產和消費程式需要停止。因為如果有程式正在生產或者消費該topic,則該topic的offset資訊一致會在broker更新。呼叫kafka delete命令則無法刪除該topic。同時,需要設定 auto....