因此，如果Kafka Consumer启用了自动提交，提交间隔为5秒，并且我们每1秒使用一个批处理......在自动提交完成之前，使用者是否会多次处理消息？
bvpmtnay1#
如果您将批处理标记为已处理，它将每5秒提交到集群中的分区。使用者发出下一个批处理轮询以获取下一组消息，因此它将从下一个偏移量开始。除非发生错误，否则不太可能再次获取同一批消息。加入Redpanda的社区slack频道，从核心工程师那里获得更多帮助：）
1条答案
按热度按时间bvpmtnay1#
如果您将批处理标记为已处理，它将每5秒提交到集群中的分区。使用者发出下一个批处理轮询以获取下一组消息，因此它将从下一个偏移量开始。除非发生错误，否则不太可能再次获取同一批消息。
加入Redpanda的社区slack频道，从核心工程师那里获得更多帮助：）