apache-kafka - 如何确定Kafka消费者偏移量

我们有一个问题，似乎 Kafka 消费者没有收到发布到主题的消息。 (我说似乎是因为我还没有深入了解这一点，我可能是错的。)

我正在为 Apache Kafka 使用 Spring，而我的消费者实际上是一个用 @KafkaListener 注释的方法。

此问题是间歇性的，我无法重新创建它。

有没有办法让我查看 Kafka 代理的日志，或任何其他工具来帮助我找出我的消费者的偏移量？ 我想要具体的证据来证明我的消费者是否收到了消息。

最佳答案

查看 kafka-consumer-groups 工具，该工具可用于检查消费者的偏移和滞后(在您运行此命令时消费者必须处于事件状态)。

./kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --new-consumer --describe --group console-consumer-55936

GROUP                          TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             OWNER
console-consumer-55936         test                           0          6               6               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           1          1               1               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           2          1               1               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           3          1               1               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           4          2               2               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           5          1               1               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           6          1               1               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           7          2               2               0               consumer-1_/192.168.0.83
console-consumer-55936         test                           8          1               1               0               consumer-1_/192.168.0.83

这应该使您能够跟踪是否实际消耗了任何东西。

关于apache-kafka - 如何确定Kafka消费者偏移量，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/42552883/