Running Kafka Producer/Consumer with Kerberos

[#1]

We are trying to setup Kafka with kerberos and facing some issue in running defaultproducer/consumer example.

Taken help from : https://community.hortonworks.com/articles/55154/kafka-ssl-kerberos-cheat-sheet-settingsconsole-com....

[tarun.kumar@aw1frtdvhdp02 bin]$ /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list localhost:6667 --topic test

Hello

[2017-05-29 14:11:56,293] ERROR Error when sending message to topic test with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

While trying to run the producer/consumer above ways seeing above error.

Can anyone please help me in understanding /resolving this ?

[#2]

@Tarun Kumar

Please add the option --security-protocol SASL_PLAINTEXT to your producer command (depending upon the security protocol that you have configured) and also instead of localhost, use broker hostname:

$ /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list <broker_hostname>:6667 --topic test --security-protocol SASL_PLAINTEXT

Thank you!