初学者在Kafka和合流包。我想开始多个经纪人,以便消费的主题。可以通过此设置完成- {'bootstrap.server' : 'ip:your_host,...',}
此设置可以在服务器配置文件中定义,也可以在脚本中定义。
但我该怎么办呢?。如果我只是向引导服务器添加多个端点,则会出现以下错误:
java.lang.illegalargumentexception:要求失败:每个侦听器必须有不同的名称,侦听器:纯文本://:9092,纯文本://:9093
初学者在Kafka和合流包。我想开始多个经纪人,以便消费的主题。可以通过此设置完成- {'bootstrap.server' : 'ip:your_host,...',}
此设置可以在服务器配置文件中定义,也可以在脚本中定义。
但我该怎么办呢?。如果我只是向引导服务器添加多个端点,则会出现以下错误:
java.lang.illegalargumentexception:要求失败:每个侦听器必须有不同的名称,侦听器:纯文本://:9092,纯文本://:9093
2条答案
按热度按时间erhoui1w1#
config/server-1.属性:
config/server-2.属性:
参考:kafka\u quickstart\u multibroker
lo8azlld2#
完成。实际上,我已经提到了生产商和消费者的同一个端口,因此这就是问题所在。在不同的端口设置代理,即使一个代理失败,也可以正常工作。