Introducing the all-new TIBCO Community site!

For current users, please click "Sign In" to reset your password and access the enhanced features. If you're a first-time visitor, we extend a warm welcome—click "Sign Up" to become a part of the TIBCO Community!

If you're seeking alternative community sites, explore ibi, Jaspersoft, and Spotfire.

Jump to content

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


Pradeep Achar 2

Recommended Posts

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)

Link to comment
Share on other sites

×
×
  • Create New...