我试图让kafka使用者在特定时间段内收集消息，然后我可以手动处理已收集的消息。但是我找不到来自shopify sarama的方法或api，可以用来提交一条消息或一批消息，请帮忙
最佳答案
使用自动提交，无论如何都无法完全控制它。它是定期的，为您在幕后发生。
如果不合适，您还可以使用ConsumerGroupSession.MarkOffset(topic string, partition int32, offset int64, metadata string)进行提交，只要您想要(即使在特定时间后)偏移量(作为一批消耗的消息中的最后一条)。
关于go - 使用Sarama单独或批量提交消息-Go的kafka客户端，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/65001853/