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

我想为同一主题创建多个使用者或一组使用者。因为我的要求是捕获所有应用程序中的事件。如果我将项目部署在2个不同的VM中，则仅将分区分配给我首先在其中部署的一个虚拟机，而对于第二个，则不会将其分配给相同的主题。

最佳答案

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