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

0

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

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

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

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

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

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

profile picture
EXPERTE
gefragt vor 6 Monaten2 Aufrufe
1 Antwort
0

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

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

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

profile picture
EXPERTE
beantwortet vor 6 Monaten

Du bist nicht angemeldet. Anmelden um eine Antwort zu veröffentlichen.

Eine gute Antwort beantwortet die Frage klar, gibt konstruktives Feedback und fördert die berufliche Weiterentwicklung des Fragenstellers.

Richtlinien für die Beantwortung von Fragen