在Kafka启动多个经纪人

uajslkp6  于 2021-06-08  发布在  Kafka
关注(0)|答案(2)|浏览(294)

初学者在Kafka和合流包。我想开始多个经纪人,以便消费的主题。可以通过此设置完成- {'bootstrap.server' : 'ip:your_host,...',} 此设置可以在服务器配置文件中定义,也可以在脚本中定义。
但我该怎么办呢?。如果我只是向引导服务器添加多个端点,则会出现以下错误:
java.lang.illegalargumentexception:要求失败:每个侦听器必须有不同的名称,侦听器:纯文本://:9092,纯文本://:9093

erhoui1w

erhoui1w1#

cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties

config/server-1.属性:

broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=/tmp/kafka-logs-1

config/server-2.属性:

broker.id=2
listeners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs-2

参考:kafka\u quickstart\u multibroker

lo8azlld

lo8azlld2#

完成。实际上,我已经提到了生产商和消费者的同一个端口,因此这就是问题所在。在不同的端口设置代理,即使一个代理失败,也可以正常工作。

相关问题