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
