【发布时间】:2019-05-28 16:41:54
【问题描述】:
KAFKA 客户端(生产者和消费者)通过连接到一个已配置的引导服务器来发现拓扑,然后它将直接与集群中的这些代理节点集一起工作。
使用这个标准的东西,我们可以通过更改引导服务器来更改生产者和消费者,而无需重新启动它们以使用不同的集群吗?我们可以在不重新启动客户端的情况下更改引导服务器配置吗?
有一个名为 metadata.max.age.ms 的客户端配置将强制客户端刷新代理拓扑,但仅涵盖新的分区领导者和添加到集群的新代理节点。
这主要是为了覆盖 DC 中的 KAFKA 集群由于某些意外原因而关闭的场景,以及来自同一个 DC 的客户端已经与同一个 DC KAFKA 集群建立连接并希望探索重定向已经启动的 KAFKA 客户端的选项与其他 DC KAFKA 集群一起工作,以防同一个 DC 集群出现故障。
【问题讨论】:
标签: apache-kafka kafka-consumer-api kafka-producer-api