duanleiliu7373 2016-11-16 21:29
浏览 879
已采纳

如何在Golang Kafka 10中获取分区的消费者组偏移量

Now that Golang Kafka library (sarama) is providing consumer group capability without any external library help with kafka 10. How can I get the current message offset being processed by a consumer group at any given time ?

Previously I used kazoo-go (https://github.com/wvanbergen/kazoo-go) to get my consumer group message offset as it is stored in Zookeeper. Now I use sarama-cluster (https://github.com/bsm/sarama-cluster), I am not sure which API to use to get my consumer group message offset.

  • 写回答

1条回答 默认 最新

  • douxi7219 2016-11-21 15:43
    关注

    I am also working with Sarama and Kafka to get offset of a topic.

    You can get offset with following code.

        package main
    
        import (
         "gopkg.in/Shopify/sarama"
         "fmt"
        )
    
        func main(){
          client , err := sarama.Client([]string{"localhost:9092"},nil) // I am not giving any configuration
          if err != nil {
              panic(err)
          }
          lastoffset, err := client.GetOffset("topic-test",0,sarama.OffsetNewest)
          if err != nil {
              panic(err)
          }
          fmt.Println("Last Commited Offset ",lastoffset)
        }
    

    Let me know if this is the answer you are looking for and if it is helpful.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 R语言爬虫的时候元素和园代码不一样怎么解决呀
  • ¥15 VS2022多项目启动有问题
  • ¥15 SQL删除添加数据后序号不连续问题。
  • ¥15 首次运行OmniEvent运行报错
  • ¥15 有没有人知道这个问题怎么解决
  • ¥15 comsol电力电缆载流量仿真
  • ¥15 webSocket可以接TCP socket接口吗
  • ¥60 mpi并行出错,CFD++计算
  • ¥15 c#:vsto,powerpoint的外接程序中换主题颜色
  • ¥15 状态机/汽车转向灯/Sateflow