卡夫卡信息监测显示发布或消耗

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脚本得到这两个数字。