apache-kafkaflume

Flume Kafka integration error "producer.SyncProducer: Disconnecting from localhost:2181"

I am getting the following error:

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.
Solution

  • You've pointed flume at Zookeeper, not a broker. Try port 9092