Ошибка интеграции Flume Kafka: «производитель.SyncProducer: отключение от локального узла: 2181»

Question

Я получаю следующую ошибку:

s20/02/15 07:31:33 INFO producer.SyncProducer: Connected to localhost:2181 for producing
20/02/15 07:31:33 INFO producer.SyncProducer: Disconnecting from localhost:2181
20/02/15 07:31:33 WARN client.ClientUtils$: Fetching topic metadata with correlation id 0 for topics [Set(flkf)] from broker [id:0,host:localhost,port:2181] failed
java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.

Answer 1

Вы указали на Zookeeper, а не на брокера . Попробуй порт 9092