如何获得golang kafka 10中分区的消费群偏移量

jtjikinw  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(380)

现在,golang kafka图书馆(sarama)正在提供消费群体功能,而无需任何外部图书馆帮助kafka 10。如何获取消费者组在任何给定时间处理的当前消息偏移量?
以前我用kazoo go(https://github.com/wvanbergen/kazoo-go)以获取存储在zookeeper中的消费者组消息偏移量。现在我使用sarama集群(https://github.com/bsm/sarama-cluster),我不确定使用哪个api来获取我的消费群消息偏移量。

sshcrbum

sshcrbum1#

我也在和萨拉玛和Kafka合作,以抵消一个主题。
你可以用下面的代码得到偏移量。

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)
    }

让我知道如果这是你正在寻找的答案,如果它是有用的。

相关问题