如果自动提交的发生频率低于轮询，Kafka Consumer 如何跟踪已处理的消息？

Question

因此，如果 Kafka Consumer 启用了自动提交，提交间隔为 5 秒，并且我们每 1 秒消费一批......

...在自动提交完成之前，消费者是否会多次处理消息？

Answer 1

如果您将批处理标记为已处理，它将每 5 秒提交到集群中的分区。消费者发出下一批轮询以获取下一组消息，因此将从下一个偏移量开始。除非发生错误，否则不太可能再次获得同一批消息。