You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jan 8, 2020. It is now read-only.
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.
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
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
The text was updated successfully, but these errors were encountered: