kafka阻塞排錯步驟

2021-07-31 02:08:45 字數 701 閱讀 8725

1.首先獲取所有的topic的列表

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

2.檢視某乙個topic下的log檔案和offset是不是一樣(下一單之後再次檢視有沒有變化,應該是log檔案和offset同時加1才對,如果不是同時加1說明阻塞)

bin/kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper localhost:2181 --group cxx_system --topic cxx_subs_topic 

3.如果發生阻塞可以通過重啟kafka來解決

首先關閉zookeeper,再關閉kafka,然後開啟zookeeper,在開啟kafka(注意順序和集群的時候,如果是集群的情況記得都要開啟)

其他說明:

檢視某乙個topic的狀態

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic某乙個名字

獲取關於某乙個topic的所有的記錄(注意:有可能獲取獲取不到值,是因為offset是非法排序的所以獲取不到值)

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic topic某乙個名字 --from-beginning

Kafka 阻塞如何排查

o 首先獲取所有的 topic 列表 bin kafka topics.sh list zookeeper localhost 2181 o 檢視某乙個 topic 下的 log 檔案和 offset 是不是一樣 下 一單之後再次檢視有沒有變化,應該是 log 檔案和 offset 同時加 1 猜對...

kafka使用步驟

1.執行zookeeper 執行zookeeper bin目錄下zkserver.cmd 不要關閉 2.執行kafka 在kafaka目錄下shift 右鍵進入命令框 a.執行 bin windows kafka topics.bat list zookeeper 127.0.0.1 2181 然後...

Kafka安裝步驟

1.安裝包 kafka 2.11 1.1.0.tgz 2.把安裝包放在 data program 資料夾下,如果沒有program資料夾,則建立乙個 mkdir program 3.解壓 tar zxvf kafka 2.11 1.1.0.tgz 4.修改 config server.propeti...