Can you take a look at KAFKA-5337 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-169+-+Lag-Aware+Partition+Assignment+Strategy) ?
Cheers On Thu, Dec 28, 2017 at 11:17 PM, 赖剑清 <laijianq...@tp-link.com.cn> wrote: > 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 > > >
