bsm/sarama-cluster

Consumer Partitions Mode is not working

dhbarman opened this issue · 1 comments

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