当前位置: 首页 > 知识库问答 >
问题:

在生成消息时,是否必须指定所有Kafka broker IP

周峻
2023-03-14
/kafka-console-producer.sh --broker-list 192.168.7.110:9092 --topic test
./kafka-console-producer.sh --broker-list 192.168.7.110:9092,192.168.5.110:9092,192.168.3.111:9092 --topic test

如果我只提供一个IP来生成消息,而该IP在某个时间后关闭,将会发生什么。我是否能够通过该IP生成消息,或者我必须提供所有的IP地址?

共有1个答案

呼延原
2023-03-14

检查生产者配置文档,这些文档描述了bootstrap.servers的用途(bootstrap-servers/broker-list是同义词):

用于建立到Kafka集群的初始连接的主机/端口对列表。

客户机将使用所有服务器,而不考虑在此指定了哪些服务器进行引导--此列表仅影响用于发现全套服务器的初始主机。此列表的格式应为host1:port1、host2:port2、....

由于这些服务器只是用于初始连接,以发现完整的集群成员身份(可能会动态更改),因此该列表不需要包含完整的服务器集(不过,如果服务器关闭,您可能需要多个服务器)。

因此,如果您只提供了一个IP,而该IP随后被关闭,那么您的生产者在尝试连接时将会失败。但是,例如,您可以提供两个IP,这样,如果其中一个IPs发生故障,生产者仍然可以连接到另一个IPs。但实际消息发送到的代理不受此影响。

请参阅这里的答案。

 类似资料:
  • 我是阿帕奇骆驼的新手。我正试图将头和请求体一起发送到Apache Camel中的路由。 我得到以下错误:

  • 目前,我正在尝试将。NET web应用程序(V.4.5.2)与ADFS2.0集成。我在网上找到的大部分文章都要求WIF信任来自联邦服务器的传入令牌。

  • 假设我有这样的xml: 签名后我得到: 事实上,

  • 本文向大家介绍Kafa consumer 是否可以消费指定分区消息?相关面试题,主要包含被问及Kafa consumer 是否可以消费指定分区消息?时的应答技巧和注意事项,需要的朋友参考一下 Kafa consumer 消费消息时,向 broker 发出"fetch"请求去消费特定分区的消息,consumer 指定消息在日志中的偏移量(offset),就可以消费从这个位置开始的消息,custome

  • 本文向大家介绍Kafka 消费者是否可以消费指定分区消息?相关面试题,主要包含被问及Kafka 消费者是否可以消费指定分区消息?时的应答技巧和注意事项,需要的朋友参考一下 Kafa consumer消费消息时,向broker发出fetch请求去消费特定分区的消息,consumer指定消息在日志中的偏移量(offset),就可以消费从这个位置开始的消息,customer拥有了offset的控制权,可

  • 我是Liquibase的新手,我尝试将liquibase与postgres数据库一起使用liquibase脚本创建数据库表。我所做的是,我已经手动创建了Postgres表并通过运行命令 mvn液化酶:generateChangeLog 我创建了liquibase-outputChangeLog.xml文件。现在我尝试更新该脚本并在数据库中创建一个表。为此,我将XML代码写入新表的ChangeLog