У меня 2 брокера кластера kafka 0.10.1, ранее запущенных на моих серверах разработки с zookeeper 3.3.6 правильно.
Я недавно пытался обновить версию брокера до последней kafka 2.3.0, но она не запустилась.В конфигурации ничего не изменилось.
Может кто-нибудь подсказать мне, что может пойти не так.Почему брокеры не начинают работу?
Изменены server.properties на сервере брокера 1
broker.id=1
log.dirs=/mnt/kafka_2.11-2.3.0/logs
zookeeper.connect=local1:2181,local2:2181
listeners=PLAINTEXT://local1:9092
advertised.listeners=PLAINTEXT://local1:9092
Изменены server.properties на сервере брокера 2
broker.id=2
log.dirs=/mnt/kafka_2.11-2.3.0/logs
zookeeper.connect=local1:2181,local2:2181
listeners=PLAINTEXT://local2:9092
advertised.listeners=PLAINTEXT://local2:9092
ПРИМЕЧАНИЕ :
1. Zookeeper работает на обоих серверах
2. Создаются каталоги Kafka, а именно /brokers, /brokers/ids, /consumers и т. Д.
3. Ничегорегистрируется под / brokers / ids.Zookeeper CLI get /brokers/ids возвращает [] 4. Команда lsof -i tcp:9082 возвращает
COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME
java 18290 cass 118u IPv6 52133 0t0 TCP local2:9092 (LISTEN)
4. logs/server.log не регистрирует ошибок.
5. Больше журналов не добавляется к server.log.
Журналы сервера
[2019-07-01 10: 56: 14,534] INFO Запуск очистителя журнала с периодом по умолчанию 9223372036854775807 мс.(kafka.log.LogManager)
[2019-07-01 10: 56: 14,801] ИНФОРМАЦИЯ Ожидание соединений с сокетом в локальной сети 2: 9092.(kafka.network.Acceptor)
[2019-07-01 10: 56: 14,829] INFO [SocketServer brokerId = 1] Создан приемник плоскости данных и процессоры для конечной точки: EndPoint (local2,9092, ListenerName (PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2019-07-01 10: 56: 14,830] INFO [SocketServer brokerId = 1] Запущены 1 потоки акцептора для плоскости данных (kafka.network.SocketServer)
[2019-07-01 10: 56: 14,850] ИНФОРМАЦИЯ [ExpirationReaper-1-Produce]: запуск (kafka.server.DelayedOperationPurgatory $ ExpiredOperationReaper)
[2019-07-01 10: 56: 14,851] INFO [ExpirationReaper-1-Fetch]: запуск (kafka.server.DelayedOperationPurgatory $ ExpiredOperationReaper)
[2019-07-01 10: 56: 14,851] INFO [ExpirationReaper-1-DeleteRecords]: запуск (kafka.server.DelayedOperationPurgatory $ ExpiredOperationReaper)
[2019-07-01 10: 56: 14,852] ИНФОРМАЦИЯ [ExpirationReaper-1-ElectPreferredLeader]: запуск (kafka.server.DelayedOperationPurgatory $ ExpiredOperationReaper)
[2019-07-01 10: 56: 14,860] ИНФОРМАЦИЯ [LogDirFailureHandler]: Запуск (kafka.server.ReplicaManager $ LogDirFailureHandler)
[2019-07-01 10: 56: 14,892] ИНФОРМАЦИЯ Создание / brokers / ids / 1 (это безопасно?false) (kafka.zk.KafkaZkClient)