Кластер Kafka не получает сообщения

Question

Я установил кластер Kafka с 3 узлами. kafka-console-producer.sh и kafka-console-consumer.sh работают так, как объявлено в кластере на локальном хосте, но когда я пытаюсь подключиться к кластеру из консольного приложения Java на другом сервере, он не будет отправлять сообщения в тему. Я использую пример кода в документации, и я также попробовал примеры на GitHub. Кажется, код соединяется без ошибок или исключений, но сообщения, похоже, не отправляются в тему.

Что я должен искать, чтобы устранить это?

Answer 1

Наконец-то нашёл ответ глубоко в сети ...

У меня не было настройки моих слушателей, поэтому он использовал каноническое имя хоста, а не IP-адрес, с которым я соединялся, поэтому после добавления IP-адреса в качестве слушателя все работает.

Конкретно

 listeners=PLAINTEXT://<ip address here>:9092