Kafka消费者：如何检查主题分区中的所有消息是否被完全消费？

Question

是否有任何 API 或属性可用于或比较以确定一个主题分区中的所有消息是否都已被消费？我们正在进行一项测试，该测试将使用同一消费者组中的另一个消费者来检查主题分区是否仍有任何消息。我们的一项应用服务也使用 Kafka 来处理内部事件。那么有没有办法同步消息消费的进度呢？

Answer 1

是的，您可以使用管理 API。

您可以从管理 API 获取每个分区的主题偏移量，以及给定的消费者组偏移量。如果所有消息都已读取，则从第一个中减去后一个的结果对于所有分区都会计算为 0。