spring boot在Kafka Java中为同一主题创建多个消费者组
我想为同一主题创建多个消费者或一组消费者。因为我的要求是从所有应用程序捕获事件。如果我在两个不同的VM中部署我的项目,分区将只分配给我首先部署的一个VM,而对于第二个VM,分区不会分配给相同的主题
你可以在下面搜索框中键入要查询的问题!
我想为同一主题创建多个消费者或一组消费者。因为我的要求是从所有应用程序捕获事件。如果我在两个不同的VM中部署我的项目,分区将只分配给我首先部署的一个VM,而对于第二个VM,分区不会分配给相同的主题
# 1 楼答案
使用者组中的使用者数量必须等于或小于主题的分区数量。如果您的主题有一个分区,并且您在同一组中创建了两个使用者,那么其中一个使用者将处于空闲状态(不会收到任何消息)。 如果分区号不够,您可以更改主题以拥有更多分区
# 2 楼答案
据我所知,您希望在每个VM中接收来自该主题的所有消息。在这种情况下,在应用程序的每个部署中,必须在使用者的属性中指定不同的
group.id