我有一个现有的应用程序，它具有基于Jms的通信，其中两个使用者节点(主动/被动(将通过Jms队列连接到生产者。这里，当第一个使用者(C1(启动时，它将成为活动节点，并开始消费队列中的事件。当第二个使用者(C2(启动时，它将是一个被动节点。如果C1下降，C2变为活动状态并开始消耗事件。当C1重新启动时，它将成为被动节点。
我正试图用Apache Kafka来转换它。使用"单一主题"时，"单一消费者组"包含两个消费者。
问题：当第一个消费者K-C1启动时，它将处于活动状态并开始消费消息当第二个消费者K-C2启动时，动物园管理员使K-C2处于活动状态。
有没有办法控制这种行为？
只要两个消费者都是无状态的，那么哪一个是主动的还是被动的都不重要。根据我的经验，分区的第一个使用者通常保持活动状态，但这在很大程度上取决于再平衡协议，而您无法控制
您可以尝试调整partition.assignment.strategy设置，尽管