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

Question

我们在内部云上有一个 kafka 代理设置。我们使用 zookeeper 找到实际的 url 并在 bootstrap.server 配置中提供。现在的问题是当代理重新启动内部云时，它会在具有新主机端口的动态分配的机器上重新启动。现在我最初在生产者配置中给出的主机端口无效。

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

注意：我知道这对于托管代理来说是一个糟糕的设计，它可以在另一台机器上重新启动，但现在就是这样。

标签： apache-kafka

Answer 1

我认为您可以在 bootstrap.server 配置中使用域名而不是 ip。