@apachekafka suggested addition to http://kafka.apache.org/documentation/#security - section 5 - Examples using console-producer and console-consumer:
echo "ssl" | /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list $KAFKABROKERSSSL --topic test2 --producer.config client-ssl.properties --security-protocol SSL note: addition of --security-protocol SSL /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --zookeeper $KAFKAZKHOSTS --bootstrap-server $KAFKABROKERSSSL --topic test2 --from-beginning --consumer.config client-ssl.properties --security-protocol SSL --new-consumer note: addition of --security-protocol SSL --new-consumer Thanks
