Connecting to a Secure Kafka

Search…
Connecting to a secure Kafka cluster may be difficult, but hopefully, this page will help you. Conduktor inherits the permissions of the user that connects to Kafka.
YouTube video walkthrough
General Idea
Conduktor leverages the default Apache Kafka Java Clients, and therefore we use the same configuration properties. If you are trying to connect to a secure Kafka cluster using Conduktor, please first try to use the CLI. If you don't know how, please contact your administrator. 
Example:
1
kafka-console-consumer \
2
    --topic my-topic \
3
    --bootstrap-server SASL_SSL://kafka-url:9093 \
4
    --consumer.config config.properties
Copied!
Your config.properties file may contain something like this:
1
security.protocol=SSL
2
ssl.truststore.location=/var/private/ssl/client.truststore.jks
3
ssl.truststore.password=test1234
4
other.configs=values...
Copied!
What Conduktor needs to connect to a secure Kafka cluster is all the values from your config.properties file.
In case you don't know what should be the values in the config.properties file, please contact your Kafka administrator. 
Note: these are the same properties you would use in your Kafka Java clients or applications. 
SSL Configuration
If client authentication is not required by the broker, the following is a minimal configuration example:
1
security.protocol=SSL
2
ssl.truststore.location=/full/path/to/kafka.client.truststore.jks
3
ssl.truststore.password=test1234
Copied!
If client authentication is required, then a keystore must be created for each client, and the brokers’ truststores must trust the certificate in the client’s keystore. Please ask your Kafka administrator for help on generating client keys. Here is a configuration example:
1
security.protocol=SSL
2
ssl.truststore.location=/full/path/to/kafka.client.truststore.jks
3
ssl.truststore.password=test1234
4
ssl.keystore.location=/full/path/to/kafka.client.keystore.jks
5
ssl.keystore.password=test1234
6
ssl.key.password=test1234
Copied!
Other configuration settings that may also be needed depending on our requirements and the broker configuration:
1.ssl.provider (Optional). The name of the security provider used for SSL connections. Default value is the default security provider of the JVM.
2.ssl.cipher.suites (Optional). A cipher suite is a named combination of authentication, encryption, MAC and key exchange algorithm used to negotiate the security settings for a network connection using TLS or SSL network protocol.
3.ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1. It should list at least one of the protocols configured on the broker side
4.ssl.truststore.type=JKS
5.ssl.keystore.type=JKS
Please make sure to put the full paths to your SSL certificates in your properties file
Relative paths may not work for Conduktor. 
SASL Configuration
Multiple SASL configurations can be done for Apache Kafka and Conduktor supports them all. In this documentation we will just cover Kerberos, but you should get a general sense of how things work. 
Here's a minimal configuration for SASL_PLAINTEXT:
1
security.protocol=SASL_PLAINTEXT
2
sasl.mechanism=GSSAPI
3
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="my-user" password="secret";
Copied!
SCRAM configuration
Use this configuration in Conduktor:
1
security.protocol=SASL_SSL
2
sasl.mechanism=SCRAM-SHA-512
3
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="yyy" password="xxx";
Copied!
🚨 About JAAS files
If you see a JAAS file being passed as a Java option to your Kafka clients using
1
-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf
Copied!
then you must you the sasl.jaas.config property as outlined above in Conduktor.
Example: the following JAAS file:
1
KafkaClient {
2
  org.apache.kafka.common.security.plain.PlainLoginModule required
3
  username="alice"
4
  password="alice-secret";
5
};
Copied!
Would be converted to the following sasl.jaas.config property:
1
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required  username="alice" password="alice-secret";
Copied!
Please make sure to put the full paths to your SASL key files in your properties file
Relative paths may not work for Conduktor. 
Example using Kerberos
Another example using Kerberos and a keytab:
a JAAS file (would need -Djava.security.auth.login.config=/path/to/jaas.conf)
1
KafkaClient {
2
  com.sun.security.auth.module.Krb5LoginModule required
3
  useKeyTab=true
4
  keyTab="/etc/security/keytabs/alice.keytab"
5
  principal="[email protected]";
6
};
Copied!
The same, but using sasl.jaas.config:
1
sasl.kerberos.service.name=kafka
2
sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab="/etc/security/keytabs/alice.keytab" principal="[email protected]";
Copied!
​
Troubleshooting  : " KrbException: Pre-authentication information was invalid " ERROR

Cause 1: The password entered is incorrect.
Solution 1: Verify the password.
Cause 2: If you are using the keytab to get the key (e.g., by setting the useKeyTab option totrue in the Krb5LoginModule entry in the JAAS login configuration file), then the key might have changed since you updated the keytab.
Solution 2: Consult your Kerberos documentation to generate a new keytab and use that keytab.
Cause 3: Clock skew - If the time on the KDC and on the client differ significantly (typically 5 minutes), this error can be returned.
Solution 3: Synchronize the clocks (or have a system administrator do so).
Cause 4: The Kerberos realm name is not all uppercase.
Solution 4: Make the Kerberos realm name all uppercase. Note: It is recommended to have all uppercase realm names. See Naming Conventions for Realm Names and Hostnames.

FAQ
Ensure you are using the Java-style configuration
If you are sure you have configured your connection properly in Conduktor and it works in other tools, make sure you're using the official configuration Java-style, and not the C-style (librdkafka). It may happen when you work with Python or nodejs (both are using librdkafka behind the scene). 
​Here are all the properties of librdkafka, some of them are different from the official Java configuration (that Conduktor supports).
For instance, the following (common) properties are NOT compatible with Conduktor:
1
sasl.username
2
sasl.password
3
enable.ssl.certificate.verification
Copied!
You need to use the Java-style syntax shown above, here with SASL_PLAINTEXT:
1
security.protocol=SASL_PLAINTEXT
2
sasl.mechanism=GSSAPI
3
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="my-user" password="secret";
Copied!
​
How to avoid SSL handshake errors?
When you setup a kafka cluster with a self-signed CA certificate (not official) because it's just for development, you might get an error from Conduktor:
org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target.
You need to ask (or extract) the certificate of your broker and reference it from your properties:
1
security.protocol=SSL
2
ssl.truststore.location=/full/path/to/kafka.client.truststore.jks
3
ssl.truststore.password=test1234
Copied!
See above SSL Configuration for more complete options.
​
Windows and paths
If you're using Windows, you may have to use slash '/' instead of backslash '\' to make the connection work. Here is an example when configuring a kerberos connection:
1
sasl.mechanism=GSSAPI
2
security.protocol=SASL_SSL
3
sasl.kerberos.service.name=kafka
4
sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab='c:/myfolder/keytab.ktf' serviceName='kafka' principal=’[email protected]';
5
ssl.truststore.location=C:/myfolder/trust.root.jks
Copied!
ERR: Illegal char <:>
If you stumbled upon this error, it means you used the "\" character in the paths (the error shows "/" but it's wrong) :
1
Illegal char <:> at index 2: ‪C:/myfolder/key.root.jks
Copied!
ERR: No Such File
If you see this error, and you are sure the path is right, try to remove the whole line and retype it yourself. You may have inserted invisible characters during copy/paste like from a Unix system (\r).
1
Failed to load SSL keystore keystore.jks‪ of type JKS
2
Caused by: java.nio.file.NoSuchFileException: c:/myfolder/keystore.jks‪
Copied!
​
Can you help us with more security troubleshooting?
Unfortunately, we cannot provide support to help you connect to your secure cluster besides what's included in the documentation. Your Kafka administrator will have the answer to your problem, please send them the link to this documentation page. Thank you!