Apache Kafka: загрузочный сервер не опознан - PullRequest
0 голосов
/ 08 мая 2019

Я пытаюсь настроить Apache Kafka для связи между двумя виртуальными машинами с CentOS в одной сети. Первоначально я настроил производителя и потребителя Kafka на одной машине, и все работало гладко. Затем я настраиваю Kafka на другой машине, и в процессе попытки установить их соединение я получаю сообщение об ошибке «bootstrap-server is not распознанная опция» (я использую самую последнюю версию Kafka, 2.2).

Это то, что я использовал для попытки подключения к производителю:

bin/kafka-console-producer.sh --bootstrap-server 10.0.0.11:9092 --topic test

А на стороне потребителя:

bin/kafka-console-producer.sh --bootstrap-server 10.0.0.11:9092 --topic test

На машине 10.0.0.11 работает сам сервер.

1 Ответ

1 голос
/ 08 мая 2019

Согласно документации Apache Kafka, которую можно найти здесь: https://kafka.apache.org/documentation/#quickstart_send, вы должны использовать свойство --broker-list для передачи адреса брокера.

Команда будет: ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

...