07-27-2017 08:29 AM - edited 07-27-2017 08:31 AM
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:
07-27-2017 08:39 AM
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.
11-16-2017 01:42 AM
i have an issue on kafka, while running the stream from producer to consumer facing an error ,
11-16-2017 01:43 AM
03-30-2018 01:00 AM
I am getting below kafka exceptions in log, can anyone help me why we are getting below exceptions?
30 08:10:51.052 [Thread-13] org.apache.kafka.common.KafkaException: Failed to construct kafka producer
30 04:48:04.035 [Thread-1] org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
Thank you all your help:
03-30-2018 01:47 PM