Почему моя продукция не может завершить метод промывки?

Question

Моя программа застряла в продукте.flush, и в центре управления слияниями нет соответствующего сообщения.

from confluent_kafka import Producer

p = Producer({'bootstrap.servers': '47.75.57.41:9092'})
p.produce('echo_topic', 'echo_message'.encode('utf-8'))
print('start flush')
p.flush()
print('finish flush')

Центр управления

Answer 1

Я забыл установить KAFKA_ADVERTISED_LISTENERS: PLAINTEXT: // брокер: 29092 для сети хоста