моя проблема в том, что я установил 2 брокера kafka и 2 узла zookeeper на разных контейнерах докеров (Ubuntu).
Вот мой файл конфигурации server1.properties
broker.id=1
############################# Socket Server Settings
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://ipaddress_server1:9092
zookeeper.файл конфигурации свойств -
dataDir=/tmp/zookeeper
# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=200
tickTime=2000
initLimit=20
syncLimit=10
это свойства как для серверов kafka, так и для серверов zookeeper.Я дал уникальный идентификатор брокера для каждого сервера, а также создал файл myid insite / tmp / zookeeper dir.
сейчас, когда я тестирую кластер kafka, создавая сообщения только по одному IP-адресу, как этот ./bin/kafka-console-producer.sh --broker-list 172.171.0.3:9092 --topic demo работает нормально.Но когда я закрываю один контейнер, который является лидером, я все равно получаю сообщения из темы.Но когда я снова запускаю потребительский скрипт, он показывает мне сообщения WARN: -
Не удалось установить соединение с узлом -1 (/172.171.0.3:9092).Брокер может быть недоступен
Теперь я не могу получить сообщения, что мне делать ???