В локальной сети у меня есть брокер cgw.local и клиент rpi.local, подключенные к одному и тому же коммутатору. Независимо от того, что я вставил в kafka.advertized.listeners: PLAINTEXT://cgw.local:9092 или PLAINTEXT://20.5.28.284:9092, или (Python) клиент BOOTSTRAP_SERVERS — ['cgw.local'] или ['20.5.28.284:9092'], после успешной подписки клиент жалуется:
Код: Выделить всё
WARNING:kafka.conn:DNS lookup failed for cgw:9092, exception was [Errno -2] Name or service not known. Is your advertised.listeners (called advertised.host.name before Kafka 9) correct and resolvable?
и не загружает никаких сообщений. Он ищет cgw, которого не существует, существует cgw.local или (динамический) 20.5.28.284.
Вот сервер свойства:
Код: Выделить всё
group.initial.rebalance.delay.ms=0
broker.id=0
log.dirs=/tmp/kafka-logs
kafka.listeners=PLAINTEXT://0.0.0.0:9092
kafka.advertised.listeners=PLAINTEXT://cgw.local:9092 # or 20.5.28.284:9092
Докер не используется, Kafka запускается непосредственно на cgw.local.
Подробнее здесь:
https://stackoverflow.com/questions/790 ... -listeners