You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jan 8, 2020. It is now read-only.
Similar to the ConsumerRebalanceListener of the Java API, it would be great to get informed by the consumer that the partition assignments have changed so related state can be updated or logged.
On first glance, adding a channel to the API where rebalance events are posted and selected in the same loop as Messages seems like a good idea.
Removals would get posted before https://github.com/bsm/sarama-cluster/blob/master/consumer.go#L267, whereas additions would get posted after the partition consumer was succesfully created, following the specifications outlined in the Java doc.
The text was updated successfully, but these errors were encountered:
Similar to the ConsumerRebalanceListener of the Java API, it would be great to get informed by the consumer that the partition assignments have changed so related state can be updated or logged.
On first glance, adding a channel to the API where rebalance events are posted and selected in the same loop as Messages seems like a good idea.
Removals would get posted before https://github.com/bsm/sarama-cluster/blob/master/consumer.go#L267, whereas additions would get posted after the partition consumer was succesfully created, following the specifications outlined in the Java doc.
The text was updated successfully, but these errors were encountered: