Как развернуть Kafka в облаке Google

Question

Я развернул Kafka в облаке Google, я изменил слушателей на

PLAINTEXT: // [внутренний IP-адрес]: 9092

И когда я пытаюсь

sudo ./bin/kafka-topics.sh --list --zookeeper [внешний IP-адрес]: 2181

Я могу получить тему в брокере.Однако, когда я пытаюсь создать сообщение для брокера Kafka

sudo ./bin/kafka-console-producer.sh --broker-list [внешний IP-адрес]: 9092 --topic test

появляется следующая ошибка:

ОШИБКА Ошибка при отправке сообщения в тест темы с ключом: null, значение: 5 байт с ошибкой: (org.apache.kafka.clients.generator.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: истек срок действия 1 записей для test-0: 1506 мс прошло с момента создания пакета плюс время ожидания

Интереснокакие свойства я установил неправильно и как это исправить?

Answer 1

Вам необходимо установить advertised.listeners для внешнего IP-адреса, чтобы клиенты могли правильно подключиться к нему.В противном случае они попытаются подключиться к внутреннему IP-адресу (поскольку advertised.listeners по умолчанию будет listeners, если явно не установлено)

Ref: https://kafka.apache.org/documentation/#brokerconfigs