dqdz6464 2019-06-12 11:42
浏览 758

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

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?

  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥15 数学的三元一次方程求解
    • ¥20 iqoo11 如何下载安装工程模式
    • ¥15 本题的答案是不是有问题
    • ¥15 关于#r语言#的问题:(svydesign)为什么在一个大的数据集中抽取了一个小数据集
    • ¥15 C++使用Gunplot
    • ¥15 这个电路是如何实现路灯控制器的,原理是什么,怎么求解灯亮起后熄灭的时间如图?
    • ¥15 matlab数字图像处理频率域滤波
    • ¥15 在abaqus做了二维正交切削模型,给刀具添加了超声振动条件后输出切削力为什么比普通切削增大这么多
    • ¥15 ELGamal和paillier计算效率谁快?
    • ¥15 蓝桥杯单片机第十三届第一场,整点继电器吸合,5s后断开出现了问题