apache-kafka - 已存储在 Kafka 中的记录的详细信息

事实上，我正在寻找一种方法来获取存储在 kafka 代理中的记录的详细信息以供操作使用。

我已经尝试过该Kafka-consumer-groups.sh工具，但它只显示指定消费者组的信息，并且没有显示其状态的单个记录或一组记录的详细信息，例如“消费与否”和“消费时间”。

实际上我的情况是，当我的生产者已经成功发送时，我的消费者偶尔不会正确消费。所以我必须确定哪里出了问题。

有什么办法可以得到这样的记录信息吗？

提前致谢！

标签： apache-kafka

您可以使用 kafka-console-consumer 获取您使用的消息的时间戳和密钥，如下所示：

kafka-console-consumer --bootstrap-server brk:port --topic urTopic  --from-beginning  --property print.key=true --property print.timestamp=true

将来，如果您想知道使用 CLI 脚本是否有可能，只需使用 --help 选项执行脚本，您就会对可能发生的事情有一个很好的描述。

此致。