kafka-go icon indicating copy to clipboard operation
kafka-go copied to clipboard

#615 - allow specifying a listener for partition assignment changes

Open nachogiljaldo opened this issue 7 months ago • 7 comments

Closes https://github.com/segmentio/kafka-go/issues/615

Adds a listener to send re-assignments to a listener. After this, it is possible to possible to provide a listener (optional) to have consumers be notified of changes in partition assignments for the current consumer.

This is useful for debugging as well as potentially other things such as dropping in-flight events for partitions that are not owned anymore.

nachogiljaldo avatar Jul 02 '24 22:07 nachogiljaldo