Java客户端配置了一个Kafka代理IP和要连接的端口,如果该代理在集群中出现故障,该怎么办



我有一个java使用者使用broker1:9092连接到kafka集群(3个代理(。然后,客户端将接收包含集群中代理的元数据,并连接到其中任何一个代理。如果我的消费者使用broker1来连接并获取元数据信息,那么会发生什么。我该如何解决这种情况。

我可以将我的java使用者指向所有代理IP和端口吗?

我可以将我的java使用者指向所有代理IP和端口吗?

是的,你可以做到。实际上,这就是为什么配置名称被称为bootstrap.servers;s";最后。

根据KafkaConsumer上的JavaDocs,您可以提供一个或多个经纪人的逗号分隔列表:

"通过使用配置指定要联系的一个或多个代理的列表来引导到集群的连接>bootstrap.servers。此列表仅用于发现群集中的其余代理,不必是群集中服务器的详尽列表(尽管您可能希望指定多个,以防客户端连接时服务器出现故障(">

最新更新