Kafka Issue

[Subash Konar <su...@gmail.com>]

 Hi team,

I am new to Kafka and I am trying to learn the basics. I have issued
command after

creating topic test in a single node cluster-

 /opt/cloudera/parcels/KAFKA-2.1.1-1.2.1.1.p0.18/lib/kafka/bin/kafka-console-producer.sh
--broker-list <ip>:9092 --topic test

And then I pass message *This Is Durga*

18/03/07 21:48:15 INFO utils.AppInfoParser: Kafka version :
0.10.0-kafka-2.1.1
18/03/07 21:48:15 INFO utils.AppInfoParser: Kafka commitId : unknown
This Is Durga

I m seeing below WARN while sending messages to consumer in the node after
I hit enter

18/03/07 21:55:30 WARN clients.NetworkClient: Bootstrap broker <ip>:9092
disconnected
18/03/07 21:55:30 WARN clients.NetworkClient: Bootstrap broker <ip>:9092
disconnected
Then I tried to check the consumer in the same node for the messages using
command.

/opt/cloudera/parcels/KAFKA-2.1.1-1.2.1.1.p0.18/lib/kafka/bin/kafka-console-consumer.sh
--zookeeper <ip>:2181 --topic test --from-beginning

I am getting below:

[console-consumer-51280_ABC.com.au-1520420365429-6c216d74-leader-finder-thread],
Failed to find leader for Set([test,0])
kafka.common.BrokerEndPointNotAvailableException: End point with security
protocol PLAINTEXT not found for broker 89.


Below is my server.properties configuration

  listeners=PLAINTEXT://<ip>/:9092
  num.network.threads=3
  num.io.threads=8
  socket.send.buffer.bytes=102400
  socket.receive.buffer.bytes=102400
  socket.request.max.bytes=104857600

Please help resolving the issue


-- 
Thanks and Regards,
Subash Konar