Consumer manager stuck on cleanup

skroutz / rafka

Kafka proxy with a simple API, speaking the Redis protocol

https://engineering.skroutz.gr/blog/kafka-rails-integration/

GNU General Public License v3.0

8 stars 0 forks source link

Consumer manager stuck on cleanup #2

Closed agis closed 7 years ago

agis commented 7 years ago

In some cases the consumer manager blocks indefinitely (probably on the WaitGroup). This happens with the ruby client when a consumer is spawned and Rafka receives a SIGTERM after the client disconnects.

[rafka] 2017/06/15 16:19:39 Waiting for consumer manager to shutdown...
[manager] 2017/06/15 16:19:39 Waiting for all consumers to finish...

Needs further investigation.