使用 Sarama - Go 客户端在 Kafka 中独立或批量生产消息

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《使用 Sarama - Go 客户端在 Kafka 中独立或批量生产消息》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我试图让 kafka 消费者在特定的时间内收集消息，之后我可以手动提交已收集的消息。但我无法从shopify sarama找到可用于提交一条消息或一批消息的方法或API，请帮忙

解决方案

使用自动提交，您无论如何都无法完全控制它何时发生。它是周期性的并且在幕后为您发生。 如果这对您来说不合适，您还可以使用 ConsumerGroupSession.MarkOffset(topic string,partition int32, offset int64,metadata string) 随时提交（因此即使在特定时间之后）将偏移量作为最后一个一批已消费的消息。

今天关于《使用 Sarama - Go 客户端在 Kafka 中独立或批量生产消息》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！