Несколько брокеров Kafka 0.7

Я пытаюсь запустить несколько брокеров, используя Kafka 0.7.2. Я получаю следующее сообщение об ошибке:Несколько брокеров Kafka 0.7

Exception in thread "kafka-acceptor" java.net.BindException: 
Address already in use at sun.nio.ch.Net.bind0(Native Method) 
    at sun.nio.ch.Net.bind(Net.java:444) 
    at sun.nio.ch.Net.bind(Net.java:436) 
    at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:214) 
    at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) 
    at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67) 
    at kafka.network.Acceptor.run(SocketServer.scala:128) 
    at java.lang.Thread.run(Thread.java:724)

Я создал две различных конфигурационные файлы для двух брокеров, и запустить его с помощью команды:

env JMX_PORT=9999 bin/kafka-server-start.sh config/server.properties 
env JMX_PORT=10000 bin/kafka-server-start.sh config/server1.properties

Я сделал то же самое с 0,8, и она работала хорошо. Я что-то упустил?

источник

2013-09-25 Priyanka

Я понял это. Сокеты java были открыты и, следовательно, ошибка. Используйте эту команду, чтобы найти открытые java-сокеты и убить их 'netstat -a -n -p | grep java' 'kill -9 pid' – Priyanka

вы на самом деле убиваете * некоторое приложение Java, которое работает на этом сокете *, а не освобождает сам сокет. –

убить процесс, используя следующую команду

sudo fuser -k 2181/tcp

источник

2016-12-30 07:38:02

Несколько брокеров Kafka 0.7

ответ

Смежные вопросы