Open
Description
Hi everyone!
Some way to provide information of what partitions this client is signed.
I think can be a method inside ReaderKafka like this:
r := kafka.ReaderConfig{
Brokers: []string{"localhost:9092"},
Topic: "topic.test",
GroupID: "test-group",
}
r.SignedPartitions(func(partitions) {
fmt.Println(partitions) // partitions parameter is a slice []int{} because a consumer can sign more than one partition
})
// It´s can be a closure function hook for when occur a rebalance it can do some action again, print, log ou something elseThis is helpful for consumer groups to debug who is assigned to what partition.
The Java client provides this kind of information.
thanks for great job!