fix dying consumer deadlock during rebalance

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

MIT License

1.01k stars 222 forks source link

fix dying consumer deadlock during rebalance #281

Closed angrz closed 6 years ago

angrz commented 6 years ago

We have seamless deploy. When new service is deployed a rebalance begins (at that moment we have the old service and the new one). While rebalance is going on the old service is shutting down and deadlock occurs.

dim commented 6 years ago

Thanks, nevertheless!