如何获取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) 
    } 

让我知道这是你要找的答案，如果它是有帮助的。