How to connect to Kafka broker using SASL_SSL
Issue
- Getting an error
java.lang.IllegalArgumentException: No serviceName defined in either JAAS or Kafka config; - When trying to configure camel-kafka endpoint option
saslMechanismto the endpoint URI, gettingorg.apache.camel.ResolveEndpointFailedExceptionand error messageThere are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{saslMechanism=SCRAM-SHA-256}]; - After resolving above SASL issues, still failed to connect to Kafka broker with
java.io.EOFExceptionand error messageConnection with myLocalHostName/192.168.1.10 disconnected;
Environment
- Red Hat Fuse (Fuse)
- 6.3
- Camel-Kafka
- The Simple Authentication and Security Layer (SASL)
- Secure Sockets Layer (SSL)
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.