Как я могу настроить брокера для общения с другими узлами? (Докер)

#docker #apache-kafka #docker-compose #confluent-platform

Вопрос:

Я создаю 3 узла брокера и 3 узла zookeeper с помощью docker-compose.yml, когда я создаю темы или создаю и получаю сообщение, оно показывает «ПРЕДУПРЕЖДЕНИЕ [AdminClient ClientID=adminclient-1] Не удалось установить соединение с узлом -2 (localhost/127.0.0.1:29092). Брокер может быть недоступен. (или, например, апачи.кафка,клиенты.сетевой клиент)»

Похоже, что лидер-брокер и последователь не могут соединиться друг с другом. Как я могу это исправить?

Комментарии:

1. Было бы здорово, если бы вы могли показать свой файл создания

2. Пожалуйста, предоставьте достаточно кода, чтобы другие могли лучше понять или воспроизвести проблему.

Ответ №1:

Вам необходимо настроить прослушиватели и настроить прослушиватель для взаимодействия между брокерами. Пример:

 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
KAFKA_LISTENERS: INSIDE://kafka:9092,OUTSIDE://kafka:9094
KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9092,OUTSIDE://localhost:9094
KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE