search

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

avoid consumer Close() hang #61

Closed dtheodor closed 6 years ago

dtheodor commented 6 years ago

unsubscribe and poll before closing the consumer to avoid Close() hang

Closes #59

Workaround for https://github.com/confluentinc/confluent-kafka-go/issues/189

agis commented 6 years ago

Let's wait for https://github.com/confluentinc/confluent-kafka-go/issues/189 before we proceed with this. Not sure if it's the suggested solution.

dtheodor commented 6 years ago

PR ready