一个应用jar包部署三台服务器.kafka也部署三台然后应用A,B,C三台都应该去kafka消费者组里创建一个消费者.但是C却永远不行,怎么重启C都不行.A和B都可以我再换台机器D也部署jar,发现D也创建不了消费者这有哪些原因可能导致? 不太了解kafka
同一个消费组能同时消费的消费者数量和topic的分区数有关,估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费,加一个分区就好