Reactor Kafka Consumer是否在终止（doOnTermimate）后再次开始消耗/开始重新平衡尝试推出Reactor Kafka消费者健康服务。了解何时使用者停止使用消息，何时不再是使用者组的一部分，以便重新加入。
yhived7q1#
终止后您需要一个进程管理员来重新启动任何终止的进程。例如，Kubernetes Pod restartPolicy终止后开始重新平衡是的，所有Kafka消费者组在终止 * 和重新启动 * 后重新平衡。这并不是Project Reactor独有的。
1条答案
按热度按时间yhived7q1#
终止后
您需要一个进程管理员来重新启动任何终止的进程。例如，Kubernetes Pod restartPolicy
终止后开始重新平衡
是的，所有Kafka消费者组在终止 * 和重新启动 * 后重新平衡。
这并不是Project Reactor独有的。