How to get consumer group offsets for partition in Golang Kafka?

Question

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.

Snehal Kumar · Accepted Answer

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.

Go Language

Similar Questions

How to pass optional parameters in Go?

What is an idiomatic way of representing enums in Go?

How to find a type of an object in Go?

On a mission to build Next-Gen Community Platform for Developers

Facebook

Twitter

Linkedin

Instagram