卡夫卡信息監測顯示發佈或消耗

Question

我有kafka安裝在我的本地服務器上，並通過一些其他的應用程序在服務器produers運行要發佈消息的經紀人我kafka服務器內，通過zookeeper我可以在實際的消息輕鬆看到我的kafka的健康狀態，它顯示我的kafka服務器內創建的所有主題，主題等內的偏移等，因此只有zookeeper無法顯示的內容是個別主題內的消息，所以有人建議使用kafka-manager工具，我安裝並運行了它，它運行良好，它顯示了很多來自我的kafka服務器的信息，但仍然無法顯示分別發佈或使用的真實消息我的kafka服務器中的消費者，所以我的問題是，有沒有一種方式/工具/代碼來找出發佈或消費的消息，我的意思是除了這個kafka-manager或我已經安裝了一些插件在同一個kafka-manager內，以便它會也顯示各自的消息。提前感謝！

Answer 1

卡夫卡經紀人無法告訴您給定消費者在特定主題上消費了多少消息。卡夫卡經紀人唯一知道的就是消費者當前的日誌偏移量和日誌的當前最大偏移量。然而，它不能告訴你在消費者實際接收到的當前偏移量之前有多少消息，因爲它不保留任何計數器，並且消費者定義了它自己的初始位置（以及能夠尋求日誌中的各個位置）。

您可以使用$KAFKA_HOME/bin/kafka-consumer-offset-checker.sh腳本得到這兩個數字。