Failed to connect to Azure event hub(AEH) from Java using kafka client

Kalikiri, Karthik 0 Reputation points
2024-05-21T20:05:23.9033333+00:00

It gets disconnected with following error when trying to connect to Azure event hub(AEH) from Java using kafka client.

2024-05-21 16:03:23.991 DEBUG 44 --- [ntainer#2-0-C-1] o.a.k.common.network.SslTransportLayer   : [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=apsdso-ne.servicebus.windows.net/10.205.70.85:9093], selector=sun.nio.ch.EPollSelectorImpl@2f27f6db, interestOps=8, readyOps=0] Failed to send SSL Close message

java.io.IOException: Broken pipe

 

AEH resets the connection

 

When we connect using java akhq kafka ui from the same network (AKS subnet), it works fine

How can we troubleshoot this issue and where to find logs which would indicate why AEH server resets the connection???

Azure Event Hubs
Azure Event Hubs
An Azure real-time data ingestion service.
585 questions
{count} votes