在本地机器上设置多代理集群时出错

Question

在Ubuntu上使用Kafka：Zookeeper启动Kafka启动主题创建生产者启动消费者启动消息在生产者和消费者之间传递良好

我创建了2个新的server.properties文件：server-1.properties：

broker.id=1
listeners=PLAINTEXT://:9093
log.dir=C:\kafka\kafka-logs-1

服务器-2。属性为：

broker.id=2
listeners=PLAINTEXT://:9094
log.dir=C:\kafka\kafka-logs-2

当我开始新经纪人时：

bin\windows\kafka-server-start.sh config\server-1.properties &

错误为：

kafka.common.KafkaException: Socket server failed to bind to 0.0.0.0:9092: Address already in use: bind

Answer 1

我在我的本地设置中遇到了同样的问题，有3个不同的vms运行kafka和1个动物园管理员，2个启动正常，除了一个。在修复了我的3个经纪人启动时没有任何问题后，我被推荐检查名称设置错误ip的 /etc/hosts

Answer 2

如果您使用多个代理，请在

服务器属性

broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs

服务器1.属性

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

server.2.properties

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

服务器3.属性

broker.id=3
listeners=PLAINTEXT://:9095
log.dirs=/tmp/kafka-logs3

Answer 3

这是因为您添加的代理都在侦听第一个代理当前正在使用的端口9092。

在server-1.properties文件中，您需要添加

port=9093

而在server-2.properties

port=9094

保留这些行listeners=PLAINTEXT：//： 9093，listeners=PLAINTEXT：//： 9094注释掉。

还要确保为每个实例使用不同的broker.id。

如果您尝试使用单个ZooGuard节点设置多代理Kafka集群，您可能会发现此视频很有用。