Unable to connect to Enterprise KAFAK topic over SSL using BW on a container

[Pradeep Achar 2]

We have a project which sends a message to our entrprise kafka topic using businessworks . The project uses SSL connectivity to establish connection with the KAFKA .The trust store and the keystore provided by the KAFAKA team works on our local businessworks studio. However, when we deploy the code to Kubernetes (Rancher), THE POD startup throws the below error and the KAFKA server connnectivity fails. Please find the error below.

org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed

Caused by: javax.net.ssl.SSLProtocolException: Unexpected handshake message: server_hello

at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:129)

at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:117)

at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:356)

at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:312)

at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:303)

at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:472)

at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1081)

at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1068)

at java.base/java.security.AccessController.doPrivileged(Native Method)

at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1015)

at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430)

at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514)

at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368)

at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291)

at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178)

at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543)

at org.apache.kafka.common.network.Selector.poll(Selector.java:481)

at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:551)

at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)

at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)

at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215)

at org.apache.kafka.clients.consumer.internals.Fetcher.getTopicMetadata(Fetcher.java:374)

at org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(KafkaConsumer.java:1949)

at org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(KafkaConsumer.java:1917)

at com.tibco.bw.palette.kafka.runtime.pojo.receiver.ReceiverMessage.run(ReceiverMessage.java:128)

at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)

at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)

at java.base/java.lang.Thread.run(Thread.java:834)