Wie man Benutzergruppen-Offsets für die Partition in Golang bekommt Kafka 10

Question

Nun, dass Golang Kafka-Bibliothek (Sarama) Benutzergruppe Fähigkeit ohne externe Bibliothek Hilfe mit Kafka 10 bietet. Wie kann ich die aktuelle Nachricht Offset von einem Verbraucher verarbeitet bekommen Gruppe zu einer bestimmten Zeit?

Zuvor habe ich kazoo-go (https://github.com/wvanbergen/kazoo-go) verwendet, um meine Consumer Group-Nachricht zu korrigieren, wie sie in Zookeeper gespeichert ist. Jetzt benutze ich sarama-cluster (https://github.com/bsm/sarama-cluster), ich bin nicht sicher, welche API zu verwenden, um meine Kundengruppe Nachricht Offset zu bekommen.

Answer 1

Ich arbeite auch mit Sarama und Kafka, um ein Thema zu kompensieren.

Sie können Offset mit folgendem Code erhalten.

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

Lassen Sie mich wissen, wenn dies die Antwort ist, die Sie suchen, und wenn es hilfreich ist.