在ubuntu上使用kafka:zookeeper启动kafka启动主题创建生产者启动消费者启动消息在生产者和消费者之间传递良好
我创建了两个新的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
3条答案
按热度按时间at0kjp5o1#
我有同样的问题,在我的本地设置与3个不同的虚拟机运行Kafka和1 zookeeper,2个启动良好,除了一个。我被要求检查的/etc/主机有错误的ip设置的名称,修复后,我的3个代理启动没有任何问题
5ktev3wc2#
如果您使用多个代理,那么在
服务器属性
server.1.1属性
服务器.2.1属性
服务器.3.1属性
inn6fuwd3#
这是因为您添加的代理都在监听port
9092
目前由第一个代理使用。在
server-1.properties
需要添加的文件而且在
server-2.properties
```port=9094