如何控制 kafka 策略以在使用相同的消费者组时分发消息



使用消费者组控制消息下发时,如何保证同一消费组内的每个消费者都能以轮循机制的方式接收消息?另外,Kafka 使用的默认策略是什么,似乎所有消息都可以一直发送给一个消费者?

一个使用者组中的使用者不会以循环方式接收记录。相反,它们为所有订阅的主题分配了不同的分区。如果您始终看到只有一个使用者收到消息,请检查您创建并订阅的主题的分区号,确保至少有多个分区。

最新更新