How to connect to Kafka broker using SASL_SSL

Solution Verified - Updated -

Issue

  • Getting an error java.lang.IllegalArgumentException: No serviceName defined in either JAAS or Kafka config;
  • When trying to configure camel-kafka endpoint option saslMechanism to the endpoint URI, getting org.apache.camel.ResolveEndpointFailedException and error message There 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.EOFException and error message Connection 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.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content