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 有赏,i卡绘世画不出
    • ¥15 如何用stata画出文献中常见的安慰剂检验图
    • ¥15 c语言链表结构体数据插入
    • ¥40 使用MATLAB解答线性代数问题
    • ¥15 COCOS的问题COCOS的问题
    • ¥15 FPGA-SRIO初始化失败
    • ¥15 MapReduce实现倒排索引失败
    • ¥15 ZABBIX6.0L连接数据库报错,如何解决?(操作系统-centos)
    • ¥15 找一位技术过硬的游戏pj程序员
    • ¥15 matlab生成电测深三层曲线模型代码