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

Question

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

Answer 1

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

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