自动更新应用代码中MSK中的brokerstring?

0

【以下的问题经过翻译处理】 一位客户正在考虑将他们的kafka工作负载迁移到MSK。他们有一个问题,即当集群发生扩展事件时,如何管理broker字符串。例如:生产者具有一个配置,其中包含一个属性:

bootstrap.servers={3个broker url的逗号分隔字符串}

现在发生了扩展事件,现在你又有了另一个broker。现在的办法是手动更新broker字符串url部分。

另一个选项是使用轮询的DNS或ALB,所有客户端(生产者/消费者)都与端点进行通信,在幕后维护broker字符串。

尽管我怀疑第二个选项是否可行,因为MSK是托管的。或者我可能误解了?

希望能得到有关如何解决此情况的指导,以便为其他客户提供帮助。

profile picture
专家
已提问 5 个月前2 查看次数
1 回答
0

【以下的回答经过翻译处理】 客户想把新添加的代理加入代理字符串,是否有特殊原因?

生产者/消费者使用bootstrap.servers获取Kafka集群的元数据,包括代理服务器列表、分区/偏移量信息以发现Kafka集群。任何代理服务器都可以成为引导服务器,因为每个代理服务器都接收元数据信息。

总之,每次添加新代理时更新引导服务器不是必需的。生产者/消费者仍然可以使用现有的代理服务器列表运行。

profile picture
专家
已回答 5 个月前

您未登录。 登录 发布回答。

一个好的回答可以清楚地解答问题和提供建设性反馈,并能促进提问者的职业发展。

回答问题的准则