Hi everyone, please help with advice - when one of the consumers is restarted (we are talking about a group of consumers with roundrobin balancing), rebalancing occurs incorrectly, partitions are distributed unevenly between consumers, and it may happen that all partitions will be assigned to 1 consumer. Can you help with advice?
This doesn’t seem related to the Kafka Connect API, as is a general client question.
When using the RoundRobinAssignor, the JavaDoc explicitly says there will be a diff of at most 1 partition assignment between all instances of the app. So if you see all partitions assigned to one of many instances, then there may be a different problem in your clients.
This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.