Назад | Перейти на главную страницу

Невозможно запустить kafka с помощью zookeeper (kafka.common.InconsistentClusterIdException)

Ниже приведены шаги, которые я сделал для решения этой проблемы:

  1. Запустить ZooKeeper
  2. Запускаем Kafka: .\bin\windows\kafka-server-start.bat .\config\server.properties

Также обратите внимание, что моя ОС - Windows

И на втором этапе происходит ошибка:

ОШИБКА Неустранимая ошибка при запуске KafkaServer. Подготовьтесь к завершению работы (kafka.server.KafkaServer) kafka.common.InconsistentClusterIdException: Идентификатор кластера Reu8ClK3TTywPiNLIQIm1w не соответствует сохраненному clusterId Some (BaPSk1bCSsKFxQQ4717R6Q) в meta.properties. Брокер пытается присоединиться не к тому кластеру. Возможно, настроил zookeeper.connect неправильно. на kafka.server.KafkaServer.startup (KafkaServer.scala: 220) на kafka.server.KafkaServerStartable.startup (KafkaServerStartable.scala: 44) в kafka.Kafka $ .main (Kafka.scala: 84) в kafka.Kafka.Kafka.Kafka.Kafka. (Kafka.scala)

Когда я запускаю .\bin\windows\kafka-server-start.bat .\config\server.properties работник зоопарка консоль возвращает:

ИНФОРМАЦИЯ [SyncThread: 0: FileTxnLog @ 216] - Создание нового файла журнала: log.1

Как исправить эту проблему, чтобы запустить кафку?

РЕДАКТИРОВАТЬ Посмотри это ответ следующие шаги решили мою проблему

Я решил эту проблему на своем компьютере (Windows 10), удалив файл meta.properties, найденный в каталоге журнала.

Сама проблема возникла после того, как я остановил и zookeeper, и сервер, а затем перезапустил их.

Я столкнулся с той же проблемой при запуске сервера Kafka на моем компьютере с Windows. Вы можете попробовать следующее, чтобы решить эту проблему:

  1. Откройте файл server.properties, который находится в папке kafka kafka_2.11-2.4.0 \ config (учитывая вашу версию kafka, имя папки может быть kafka_ <kafka_version>)
  2. Искать запись log.dirs
  3. Если ваш путь log.dir содержит путь к каталогу Windows, например E: \ Shyam \ Software \ kafka_2.11-2.4.0 \ kafka-logs, который имеет одинарную обратную косую черту, то есть измените ее на двойную обратную косую черту, то есть с \

Обычно эта проблема возникает, когда журналы kafka хранятся в постоянной папке, а данные zookeeper - во временной, или наоборот. Затем после перезапуска системы файлы, хранящиеся во временном каталоге, очищаются и регенерируются, что приводит к несоответствию конфигурации.

Чтобы эта ситуация не повторилась, исправьте log.dirs параметр kafka в server.properties и dataDir параметр zookeeper в zookeeper.properties и убедитесь, что оба указывают на один и тот же тип каталога (например, временный или постоянный). Только после этого сбросьте несогласованные данные (если есть), используя, например, метод из ответа Джейкоба, т.е. удалить meta.properties файл и перезапустите zookeeper и kafka.

Если вы не против потери данных, вы можете удалить папку «data» в kafka и перезапустить kafka. Если вы использовали расположение по умолчанию, папка с именем «data», вероятно, находится в / tmp / kafka-logs.

Попробуйте следующее ...

  1. Включите следующую строку в ./config/server.properties

    слушатели = PLAINTEXT: //: 9092

  2. Изменить каталог данных ZooKeeper по умолчанию

  3. Изменить каталог журнала Kafka по умолчанию

Пробовать удалите kafka-logs из папки tmp, который находится в C: / tmp папка по умолчанию в Windows и может быть установлена ​​в файле [your-kafka-folder] /config/server.properties как log.dirs

Удалите /tmp/kafka-logs/meta.properties, в котором сохранен неверный cluster.id последнего / неудачного сеанса:

#
broker.id=0
version=0
cluster.id=kzRHvVl-Rb2DZaHSqlTfow     <===