Ошибка в аргументе списка брокеров в Kafka Producer - PullRequest
0 голосов
/ 11 сентября 2018

Я запустил док-контейнер от Wurstmeister Kafka с командой:

docker run -ti --name sender --entrypoint /bin/bash wurstmeister/kafka:latest

Тогда я использую команду:

docker exec -ti <container_id> bash

, чтобы войти внутрь контейнера. Однажды в bash я пытаюсь настроить производителя Kafka для отправки сообщений. Сервер Kafka находится в виртуальной машине в облаке с публичным адресом 192.168.25.21. Когда я запускаю команду внутри контейнера:

/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.25.21:9092 --topic test

Я получаю сообщение об ошибке в аргументе списка брокеров. Аргумент списка брокеров хочет получить строку в качестве аргумента и распознает 192.168.25.21 как число. Если я использую DNS-имя другого сервера, он работает нормально. Однако я хочу иметь возможность использовать IP, как описано ранее. Есть предложения?

1 Ответ

0 голосов
/ 12 сентября 2018

Итак, --entrypoint /bin/bash должен уже поместить вас в терминал, без причины снова exec -ti.

В любом случае, по моему опыту, IP-адреса должны работать нормально, но вы можете процитироватьэто --broker-list '192.168.25.21:9092'.Тем не менее, я обычно использую экспортированную переменную среды строки как минимум для трех адресов брокера, затем использую ее из любого инструмента CLI, а не многократно копирую и вставляю IP или хост

BTW, не видя необходимостиДокер здесь.Если вы не можете / не хотите устанавливать Java или загружаете сами Kafka, kafkacat - хорошая альтернатива

...