Consumer Partitions Mode is not working
dhbarman opened this issue · 1 comments
dhbarman commented
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
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 - IBM/sarama#1099