有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

spring boot在Kafka Java中为同一主题创建多个消费者组

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


共 (2) 个答案

  1. # 1 楼答案

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

  2. # 2 楼答案

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