Запуск нескольких брокеров Kafka не удается

При попытке запустить несколько брокеров Kafka с различными брокерскими. Один из них по умолчанию - server.properties, а другой - serverTest.properties с 2-мя линиями, которые были broker.id=1 и listeners=PLAINTEXT://localhost:6000. Остальное - это та же настройка по умолчанию. Сначала я запускаю zookeeper, затем по умолчанию kafka server.properties, тогда при запуске serverTest.properties я получаю следующее исключение: kafka.common.InconsistentBrokerIdException: Configured brokerId 1 doesn't match stored brokerId 0 in meta.properties. Мое понимание состоит в том, что следующее выше должно фактически запускать несколько узлов, как я видел, что другие делают в учебниках. Я использую Kafka 9.0.Запуск нескольких брокеров Kafka не удается

источник

2016-06-28 TheM00s3

Edit Config/serverTest.properties и заменить существующие значения конфигурации следующим образом:

broker.id=2 
port=9093 
log.dir=/tmp/kafka-logs-2

Если вы хотите третьего брокера:

cp config/server.properties config/server3.properties

Edit Config/server3.properties и заменить существующий значения конфигурации:

broker.id=3 
port=9094 
log.dir=/tmp/kafka-logs-3

Если вы работаете на разных машинах, вы должны cha Нге

advertised.host.name=192.168.x.x

еще, если вы работаете в одной и той же VMWare машины, к примеру, вы должны только изменить порт и log.dir, как описано выше

источник

2016-06-28 01:29:17 xXxpRoGrAmmErxXx

Мое понимание заключалось в том, что 'listeners = PLAINTEXT: // localhost: 6000' должно было запустить его на части' 6000'. – TheM00s3

Из вашего редактирования выше. Если я оставляю только списки и просто меняю порт, один тест, который я сделал, - это перейти к этому порту в веб-браузере. Я отмечаю, что в 9092 году Kafka упомянет о получении недопустимого байтового количества, а то же самое с 'localhost: 6000' ничего не делает. Я хочу запустить брокера kafka, который можно подключить через порт 6000 в настройках бутстрапа на клиенте kafka java. – TheM00s3

Порт 6000 - это порт по умолчанию для X Windows, поэтому убедитесь, что у вас нет другого конфликта, не связанного с Kafka. Лучше всего избегать всего диапазона 6000-6063 - http://www.networksorcery.com/enp/protocol/xwindow.htm –

И, говоря от опыта, не забудьте отредактировать broker.id в файлах kafka-logs - */meta.properties в соответствии с вашими изменениями (или удалять файлы и позволять кафке восстанавливать их).

источник

2017-03-13 15:50:10

Запуск нескольких брокеров Kafka не удается

ответ

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