当前位置: > > > > 读取来自 kafka 的最新消息-segmentio/kafka-go
来源:stackoverflow
2024-04-24 12:06:29
0浏览
收藏
在IT行业这个发展更新速度很快的行业,只有不停止的学习,才不会被行业所淘汰。如果你是Golang学习者,那么本文《读取来自 kafka 的最新消息-segmentio/kafka-go》就很适合你!本篇内容主要包括##content_title##,希望对大家的知识积累有所帮助,助力实战开发!
问题内容
我正在使用segmentio/kafka-go客户端来读取主题中的消息。 我无法找到..如何从上一条/新消息开始阅读。
每次启动代码时,它都会从该分区中的起始偏移量开始读取。
解决方案
关于从 Kafka 消费消息,您需要了解的是,每个消费者客户端都是 的一部分。Kafka 将主题分区级别的每个消费者组已处理的偏移量存储在名为 __consumer_offsets
的内部 Kafka 主题中。这使得消费者组的消费者可以在重新启动后从中断处继续消费。
在你的情况下,这意味着你需要设置消费者组(在中它是配置“group.id”)并保持不变。只有这样您才能继续阅读最新/最新的消息,而不是在重新启动后从头开始。
以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持!更多关于Golang的相关知识,也可关注公众号。