开始在卡夫卡多个经纪人(Start multiple brokers in kafka)

2019-10-29 06:28发布

初学者在卡夫卡和融合package.I要启动多个代理,从而消耗的话题。 它可以通过此设置来完成- {'bootstrap.server' : 'ip:your_host,...',}

此设置可以在服务器配置文件或其他脚本,以及定义。

但是,我应如何运行这些? 如果我只需要添加多个端点,以引导服务器,它提供了这个错误:

java.lang.IllegalArgumentException异常:要求失败:每个听者必须有一个不同的名称,听众:PLAINTEXT://:9092明文://:9093

Answer 1:

完成。 我实际上提到相同的端口用于生产和消费,因此是问题。 建立经纪人不同的端口,并能正常工作,即使一个经纪人下降。



文章来源: Start multiple brokers in kafka