我们在内部云上安装了kafka broker。我们使用zookeeper找到实际的url,并在bootstrap.server配置中提供。现在的问题是,当代理重新启动内部云时,它会使用新的主机端口在动态分配的机器上重新启动。现在,我最初在生产者配置中给出的主机端口无效。
问题是如何在不重新启动的情况下重新加载此配置。
注意:我知道这是一个糟糕的设计主机代理,它可以在不同的机器上重新启动,但这就是现在的情况。
我认为你可以在bootstrap.server配置中使用域名而不是ip。