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

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

我还与Sarama和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)    }

让我知道这是否是您要找的答案，是否有帮助。