kafka启动报这个错,啥原因呢
确认当前topic的partition数量要与消费者同时消费消息的线程数对应
分区数和消费线程数设置为一样?@青牛
@ling775000 从源码中看是当topic的消费线程数量大于这个topic的分区数量时才会报这个异常,也就是有的消费线程没有分区让它消费,可以把消费线程的数量设置小点,或者把topic的分区设置多点。
`单行代码`
关注海汼部落