在代理重新启动时重新加载 kafka 生产者的 bootstrap.server 配置

Question

我们在内部云上设置了一个KAFKA代理。我们使用Zookeeper找到实际URL，并在Bootstrap.Server配置中提供。现在，问题是当经纪人重新启动内部云时，将其重新启动，并在带有新主机端口的动态分配的机器上重新启动。现在，我最初在生产者配置中给出的主机端口无效。

问题是如何在不重新启动的情况下重新加载此配置。

注意：我知道这是一个不好的设计，可以主持经纪人可以在其他机器中重新启动，但这就是现在的方式。

Answer 1

我认为您可以在bootstrap.server.server config。