在kafka中启动多个经纪人

Question

Kafka初学者和融合包。我想启动多个代理，以便了解主题。可以通过此设置完成-{'bootstrap.server'：'ip:your_host，…'，}

此设置可以在服务器配置文件中定义，也可以在脚本中定义。

但是我该如何运行它们呢？。如果我只是向引导服务器添加多个endpoint，就会出现以下错误:

Java . lang . illegalargumentexception:要求失败:每个侦听器必须有不同的名称，listeners: PLAINTEXT://:9092，PLAINTEXT://:9093

Answer 1

完成了。我实际上提到了生产者和消费者的同一个端口，因此这就是问题所在。在不同的端口上设置代理，即使一个代理关闭也能正常工作。

Answer 2

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

配置/服务器-1.属性：

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

配置/服务器-2.属性：

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

参考:kafka_quickstart_multibroker