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

0

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

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

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

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

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

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

profile picture
전문가
질문됨 6달 전2회 조회
1개 답변
0

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

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

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

profile picture
전문가
답변함 6달 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠