Запуск kafka-console-producer.sh на другой сервер

Question

Я установил Apache Kafka на свой сервер Centos.Я просто пытаюсь написать сообщение в тему на другом сервере.Поэтому после установки я НЕ запускал zookeeper или сервер Kafka, а просто набрал команду:

echo testing | ./kafka-console-producer.sh --broker-list xxx.yyy.com:2181 --topic topicx

Я могу пропинговать xxx.yyy.com с моего сервера.Когда я запускаю это, я получаю эту ошибку:

Ошибка при отправке сообщения в cds_organization темы с ключом: null, значение: 7 байт с ошибкой:
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: тема topicx отсутствует в метаданных после 60000 мс.

Так что в этом случае мне все еще нужнозапустить зоопарк и / или кафку сервер?

Answer 1

". / Kafka-console-producer.sh --broker-list xxx.yyy.com:2181 --topic topicx ", ваша запятая, пропустил эту часть, ваш брокер прослушивает PORT2181, обычно это будет 9092.Измените запятую на ". / Kafka-console-producer.sh --broker-list xxx.yyy.com:9092 --topic topicx " и повторите попытку

Answer 2

Я, наконец, получил это работает. Проблема заключалась в том, что сервер Kafka, на который я пытался написать тему, был на версии 0.8.2.1, и я установил последнюю версию. Когда я установил ту же версию, kafka-console-producer.sh работал нормально, БЕЗ запуска ни zookeeper, ни локального сервера Kafka.

Answer 3

Я НЕ запускал zookeeper или сервер Kafka, а просто набрал команду:

Если ни один из них не запущен, ни одна из перечисленных вами команд не должна работать.

мне все еще нужно запустить сервер zookeeper и / или kafka

Да, вам нужно, чтобы оба были запущены, но не обязательно должны быть на одной и той же машине.

---

Как уже упоминалось, порт Кафки по умолчанию - 9092. Zookeeper - 2181. Кажется, вы их смешали.

Команда описания тем (kafka-topics) выполняется через Zookeeper только ( вплоть до Кафки 2.2 ).

Для создания вы должны использовать хост и порт Kafka (начиная с 0.9 Kafka).