读取来自 kafka 的最新消息-segmentio/kafka-go

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《读取来自 kafka 的最新消息-segmentio/kafka-go》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我正在使用segmentio/kafka-go客户端来读取主题中的消息。 我无法找到..如何从上一条/新消息开始阅读。

每次启动代码时，它都会从该分区中的起始偏移量开始读取。

解决方案

关于从 Kafka 消费消息，您需要了解的是，每个消费者客户端都是 Consumer Group 的一部分。Kafka 将主题分区级别的每个消费者组已处理的偏移量存储在名为 __consumer_offsets 的内部 Kafka 主题中。这使得消费者组的消费者可以在重新启动后从中断处继续消费。

在你的情况下，这意味着你需要设置消费者组（在KafkaConsumer API中它是配置“group.id”）并保持不变。只有这样您才能继续阅读最新/最新的消息，而不是在重新启动后从头开始。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。