Here is what i see the logs .. So, it seems the Kafka Broker is starting up with SSL, however - when the Controller is not able to connect to the Broker
server.log > > [2017-07-24 20:57:19,461] INFO [ThrottledRequestReaper-Produce], Starting > (kafka.server.ClientQuotaManager$ThrottledRequestReaper) > [2017-07-24 20:57:19,464] INFO [ThrottledRequestReaper-Fetch], Starting > (kafka.server.ClientQuotaManager$ThrottledRequestReaper) > [2017-07-24 20:57:19,467] INFO Will not load MX4J, mx4j-tools.jar is not > in the classpath (kafka.utils.Mx4jLoader$) > [2017-07-24 20:57:19,474] INFO [Group Metadata Manager on Broker 1001]: > Removed 0 expired offsets in 7 milliseconds. > (kafka.coordinator.GroupMetadataManager) > [2017-07-24 20:57:19,498] INFO Creating /brokers/ids/1001 (is it secure? > false) (kafka.utils.ZKCheckedEphemeral) > [2017-07-24 20:57:19,508] INFO Result of znode creation is: OK > (kafka.utils.ZKCheckedEphemeral) > [2017-07-24 20:57:19,510] INFO Registered broker 1001 at path > /brokers/ids/1001 with addresses: PLAINTEXT -> EndPoint( > nwk2-bdp-kafka-04.gdcs-qa.apple.com,6668,PLAINTEXT),SSL -> EndPoint( > nwk2-bdp-kafka-04.gdcs-qa.apple.com,6667,SSL) (kafka.utils.ZkUtils) > [2017-07-24 20:57:19,526] INFO [Kafka Server 1001], started > (kafka.server.KafkaServer) controller.log [2017-07-24 20:59:56,323] WARN > [Controller-1001-to-broker-1001-send-thread], Controller 1001's connection > to broker nwk2-bdp-kafka-04.gdcs-qa.apple.com:6667 (id: 1001 rack: null) > was unsuccessful (kafka.controller.RequestSendThread) > java.io.IOException: Connection to > nwk2-bdp-kafka-04.gdcs-qa.apple.com:6667 (id: 1001 rack: null) failed > at > kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) > at > kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) > at > kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) > at > kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) > at > kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) > at > kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) > at > kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) > at > kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) On Mon, Jul 24, 2017 at 12:36 PM, karan alang <karan.al...@gmail.com> wrote: > Hello - i've enabled SSL for Kafka, and Kafka is starting up fine with SSL > enable. > > However, when i run the Kafka console producer, it is give me error as > shown below -> > > > > 1. Command : > 2. > 3. /usr/hdp/2.5.3.0-37/kafka/bin/kafka-console-producer.sh --broker-list > nwk2-bdp-kafka-05.gdcs-qa.apple.com:6667,nwk2-bdp-kafka-04.gdcs-qa. > apple.com:6667,nwk2-bdp-kafka-06.gdcs-qa.apple.com:6667 --topic > sslTopic --producer.config /tmp/ssl-kafka/client-ssl.properties > 4. > 5. Message Typed on console : > 6. hi > 7. > 8. On Typing message on the Console Producer, i get the following > error : > 9. > 10. [2017-07-24 19:10:22,940] WARN Bootstrap broker nwk2-bdp-kafka- > 06.gdcs-qa.apple.com:6667 disconnected (org.apache.kafka.clients.Netw > orkClient) > 11. [2017-07-24 19:10:23,106] WARN Bootstrap broker nwk2-bdp-kafka- > 05.gdcs-qa.apple.com:6667 disconnected (org.apache.kafka.clients.Netw > orkClient) > > > Attached is the client-ssl.properties file, used to start the Console > produce > >
