Hi, all I met a problem while using Kafka as a message queue.
I have 10 consumer servers and 3 of them have worse performance. In this case, I set my topic with partitions=17, and I hope that 7 powerful consumer servers consume 2 partitions/server while these 3 weaker server consume only one partition/server. Can this requirement realized used the official consumer-api or I should implement the balance strategy by myself? I use java. Thank you! Best regards ------------------------------------------------------------------------------------------------------------------------------------------- Jean jeanking...@gmail.com
