使用go获取kafka中所有组的所有主题的消费者组偏移量

注意:没有重复项</ strong> 如何在Golang Kafka 10中获取用于分区的消费者组偏移量无法回答 我的问题是,它甚至都不是一个可行的解决方案</ p>

我正在尝试编写一个函数,该函数向kafka查询所有主题的所有消费者组偏移量。</ p>

为此,我希望阅读 __ consumer_offsets </ code>主题中的所有消息并对其进行解析。</ p>

但是,在所有的kakfa go库中,我看起来 通过,我找不到不消耗它们就从 __ consumer_offsets </ code>中读取所有消息的方法。</ p>

kafka -go </ code>要么给我一种读取单个分区的方式,要么给我整个主题的消费</ em>消息)</ p>

所以我的问题是 放:有没有办法使用那里的任何kafka库, </ p>

如果没有,是否可以获取给定主题和组ID的消费组偏移量?</ p>
</ DIV>

展开原文

原文

NOTE: NOT A DUPLICATE OF How to get consumer group offsets for partition in Golang Kafka 10 does not answer my question, it's not even a working solution

I'm trying to write a function in go that queries kafka for all consumer group offsets for all topics.

To do that, I was hoping to read all the messages in __consumer_offsets topic and parse them.

However, in all the kakfa go libraries I looked through, I could not find a way to just read all the messages from __consumer_offsets without consuming them.

(kafka-go either gives me a way to read from a single partition, or consume messages from the entire topic)

So my question is, simply put: Is there a way, using any kafka library out there, to get consumer group offsets for all the groups for all the topics?

If not, is there a way to get the offset for a given topic and group id?

drjgk44268
drjgk44268 顺便说一句,这个库已经可以满足您的要求(使用Sarama)github.com/linkedin/Burrow
大约一年之前 回复
duanming7833
duanming7833 您指向的问题的答案提供了一种获取主题偏移量的方法,而不是获取阅读主题的组的消费者偏移量的方法
大约一年之前 回复
dpwjx32578146
dpwjx32578146 GolangKafka10中如何获取分区的使用者组偏移量的可能重复项
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问