Брокер Kafka недоступен с локального хостинга

Question

Я установил kafka_2.11-1.1.0 и установил для объявленного слушателя значение advertised.listeners=PLAINTEXT://<my-ip>:9092 (в $KAFKA_HOME/config/server.properties).

Я могу подключиться и написать в свою kafka, используя java-код, и увидеть свой кластер через kafka-tool с другого сервера, но я не могу писать сообщения в свою тему с моей локальной машины (той, на которой я установил kafka).кластер на нем).

Я также пытался установить для слушателей значение listeners = PLAINTEXT://:9092, но изменений не произошло.Что я должен сделать с моей кафкой, чтобы сделать ее доступной и доступной для записи как снаружи, так и внутри localhost?

Answer 1

Просмотрите следующие ссылки, это может быть полезно для вашего сценария:

• Доступ к Kafka внутри и снаружи докера

• Слушатели Кафки - Объясненные

Answer 2

Я наконец решил проблему, изменив библиотеку org.apache.kafka своего кода с версии 1.1.0 на версию 2.1.0.

Я упоминаю, что все эти библиотеки были импортированы (загружены) и использованы через mvnrepository.com.

Кроме того, наш код производителя и пользователя kafka был написан с использованием этой статьи: https://dzone.com/articles/kafka-producer-and-consumer-example.

Answer 3

В server.properties используйте эти два следующих свойства

listeners=PLAINTEXT://0.0.0.0:9092 
advertised.listeners=PLAINTEXT://<your ip>:9092