Я новичок в Apache Kafka и немного любитель Ubuntu, на котором я его запускаю (Ubuntu 18.04 и Kafka 2.12-2.3.0). Я следовал руководству, которое научило меня использовать инструменты командной строки, которые поставляются с Kafka, такие как "bin/kafka-console-consumer.sh" и другие. Я следовал учебному пособию, развернул экземпляр Zookeeper, развернул сервер Kafka, создал тему, создал продюсера и потребителя - все это в командной строке. Все работало и было хорошо. Я остановил все, попробовал еще раз. На этот раз, однако, команда:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicName
, похоже, не возвращала название темы, которая была создана. Это ничего не вернуло, поэтому я просто предположил, что это сработало. Я продолжал создавать продюсера, который нормально запускался, используя команду:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicName
Я начал вводить тестовые сообщения для отправки и получил сообщение об ошибке вроде:
WARN Error while fetching metadata with correlation id 3 :
{topicName=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Хотя, если я создаю потребителя для этой темы, потребитель все равно получает сообщения, которые я ввожу в CLI производителя. К настоящему времени я предположил, что предыдущая команда для создания темы не работала. Я пытаюсь создать тему с именем topicName снова, тот же результат. Нет сообщения об ошибке, ничего, просто следующая строка. Я пытаюсь ввести только команду без параметров, чтобы получить справку, просто bin/kafka-topics.sh. Ничего. Любопытно, я открываю файл .sh в текстовом редакторе, и он полностью пуст. Я не знаю, что не так, поэтому я закрыл все и перезапустил все, Zookeeper, Kafka и все, в надежде, что это как-то все исправит сам. Это не так, и теперь bin/kafka-console-consumer.sh тоже перестает работать. Я тоже открываю этот файл .sh, и он тоже пустой!
Я не уверен, что делаю что-то здесь, что приводит к стиранию самих файлов .sh. Есть ли способ вернуть их обратно, если не считать переустановки Kafka? Может кто-нибудь сказать мне, что я здесь делаю не так?