Reply
Cloudera Employee
Posts: 198
Registered: ‎01-09-2014

Re: Timeout Error When Using kafka-console-consumer and kafka-console-producer On Secured Cluster

[ Edited ]

This is indicating that your jaas.conf references a keytab that needs a password, or you are using ticket cache without doing a kinit before running this command.

Confirm that you are able to connect to the cluster (hdfs dfs -ls /) from the command line first, and then check your jaas.conf based on this documentation:
https://www.cloudera.com/documentation/kafka/latest/topics/kafka_security.html

-pd

Highlighted
Explorer
Posts: 10
Registered: ‎07-17-2017

Re: Timeout Error When Using kafka-console-consumer and kafka-console-producer On Secured Cluster

OK, finally got everything working.

 

As for the last error I had been seeing, I had thought for sure my kerberos credentials were still showing up in klist, but this morning when I kinited in, everything worked fine, so that must have been the issue.

 

I then got an error on the consumer side, which I soon realized was because with the new bootstrap-servers parameter, you need to use the same port as the producer (9093 in my case), not the zookeeper port. Once I updated this, everything worked properly.

Announcements