在kafka-java中为同一主题创建多个使用者组

5w9g7ksd  于 2021-06-06  发布在  Kafka
关注(0)|答案(2)|浏览(458)

我想为同一主题创建多个使用者或一组使用者。因为我的要求是从所有应用程序捕获事件。如果我在两个不同的vm中部署我的项目,分区将只分配给我首先部署的一个vm,而对于第二个vm,分区不会分配给相同的主题。

lf5gs5x2

lf5gs5x21#

使用者组中的使用者数必须等于或小于主题所具有的分区数。如果您的主题有一个分区,并且您在同一个组中创建了两个使用者,那么其中一个使用者将处于空闲状态(不会接收任何消息)。如果分区号不够,您可以更改主题以拥有更多分区。

lmvvr0a8

lmvvr0a82#

据我所知,您希望在每个vm中接收来自该主题的所有消息。在这种情况下,必须指定不同的 group.id 在应用程序的每个部署的使用者的属性中。

相关问题