0

我正在寻找瓦里安来解决我的问题。在测试中,一个主题有两个分区。为此主题创建了两个消费者,并订阅了它。所有消费者都有一个 UUID,例如 ce24f096-2709-4e0a-946a-61ca6cb64780 和 22ba2c2a-66cb-4da0-97be-2570a731ae2c。对于消费者获取消息,使用像 http://rest-proxy:8082/consumers/consumer-group/instances/consumer1/records 和 http://rest-proxy:8082/consumers/consumer-group/instances/consumer2 这样的网址/记录。在第二个消费者和 MAX_SESSION_TIMEOUT_MS 组重新平衡后,一个消费者从两个分区读取消息正常且可预测。在启动第二个消费者并尝试从主题获取消息后出现错误消费者实例未找到,因为它被删除了。我认为如果第二个消费者不要求 5 分钟,如何不能长时间从组中删除消费者,并重新平衡组。并且可以在可达后得到消息。

4

0 回答 0