使用消费者组控制消息下发时,如何保证同一消费组内的每个消费者都能以轮循机制的方式接收消息?另外,Kafka 使用的默认策略是什么,似乎所有消息都可以一直发送给一个消费者?
一个使用者组中的使用者不会以循环方式接收记录。相反,它们为所有订阅的主题分配了不同的分区。如果您始终看到只有一个使用者收到消息,请检查您创建并订阅的主题的分区号,确保至少有多个分区。
使用消费者组控制消息下发时,如何保证同一消费组内的每个消费者都能以轮循机制的方式接收消息?另外,Kafka 使用的默认策略是什么,似乎所有消息都可以一直发送给一个消费者?
一个使用者组中的使用者不会以循环方式接收记录。相反,它们为所有订阅的主题分配了不同的分区。如果您始终看到只有一个使用者收到消息,请检查您创建并订阅的主题的分区号,确保至少有多个分区。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium