search

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

Consumer Partitions Mode is not working #282

Closed dhbarman closed 5 years ago

dhbarman commented 5 years ago

I created a topic with 3 partitions. Following this example but it is not working. That is, case part, ok := <-consumer.Partitions(): does not return any value.

https://github.com/bsm/sarama-cluster/blob/master/examples_test.go

dim commented 5 years ago

Hmm, it's most likely not receiving any or not rebalancing correctly. You could enable returning notifications and errors in the configuration and log the output. More importantly, sarama-cluster is now deprecated, since my sarama PR has been merged - https://github.com/Shopify/sarama/pull/1099