Support Questions
Find answers, ask questions, and share your expertise

Problem when connect Nifi to Kafka

Problem when connect Nifi to Kafka

New Contributor

I have trying to running a ConsumeKafka_2_6 processor to pull message from Kafka. The Kafka have SSL protocol so my processor have a StandardSSLContextService attach to it, I create it with the truststore and keystore file provided by the Kafka. It seem fine when created, but when I run my processor it show this error org.apache.kafka.common.errors.sslauthenticationexception: ssl handshake failed. Any body have faced the same problem, please give me a hint. Thank you guy very much.

1 REPLY 1

Re: Problem when connect Nifi to Kafka

Rising Star

I would suggest checking the keystores you're using in the nifi consumer with a simple producer/consumer in the kafka host itself, for example:

 

Create a file called client.properties and add the SSL details, example below:

 

https://docs.cloudera.com/HDPDocuments/HDP3/HDP-3.1.0/configuring-wire-encryption/content/configurin...

 

Then run the consumer and see if the issue is replicated, if yes, you can enable debugging for the client to get more details about the exception.

 

I hope that helps to find the root cause.