A way to retrieve what partitions where consumer is signed

[romani-felipe]

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 else

This 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!

[achille-roussel]

Hello @romani-felipe, thanks for opening this issue!

The change you're suggesting sounds interesting, would you be able to submit a pull request implementing the feature?

Happy to discuss implementation details in this issue as well if you have questions about how to go about making the change.

[romani-felipe]

@achille-roussel Sure!

In next days i will start the implementation and will update this issue.

[achille-roussel]

Hello @romani-felipe!

I wanted to cycle back on this and ask if you still needed this feature, or maybe you had found a workaround?