kafka消费者只有三个线程有效？

Question

让kafka消费两个主题，两个主题加起来有五个partition，开了五个线程，让其消费，正常应该是一个线程消费一个partition的数据，不过结果只有三个线程有效消费，另外两个线程无效，如图：

请问有人清楚是怎么回事？

Answer 1

后来看了下代码 发现多个TOPIC消费的时候最大线程数取决于当中最多分区的一个TOPIC。
也就是说FREIGHT有三个分区，那无论你怎么加线程，最多也只能是三个线程有效。

可以换一种分配方式就搞定这个多个TOPIC的问题了。