我们将我们的kafka消费者指向用于负载平衡的分区场。
当使用rest控制器端点暂停kafka使用者时，服务只暂停少数分区，而不是所有分区。我们希望暂停所有分区，但即使重复调用也无法获得所有分区。你建议我们如何做到这一点？Hazelcast？
感谢
consumer.pause()只会暂停调用它的实例，而不会暂停整个使用者组。
负载均衡器不能针对所有包装消费者的REST端点，因为请求是在所有实例之间随机路由的，所以是的，您需要某种外部变量。动物园管理员将是一个更好的选择，除非你已经有一个Hazelcast系统。Apache Curator是一个高级Zookeeper客户端，可以用于此操作。例如，可以为暂停的0状态设置共享计数器，为非暂停设置非零计数器。