一个生产者的消息如果没有key值,则会随机到每个分区,
搭建时出了个问题,因为kafka配置文件默认partition为1,所以在我本地两个消费者始终有一个消费者消费不到消息,
后面改完配置文件分区设置2个,but 没起作用,依然只有一个消费者能消费到消息
各种查。。。网上也是都在说topic会发送到不同的partition,不同的partition会对应不同的消费者,吴国。。。
后面在生产者新建一个topic_b 然后好了,看来是一个topic在生成时就会有一些操作来对应partition,后面在查阅。
原文:https://www.cnblogs.com/imaye/p/11186459.html