Kafka-ui with azure event hub, java.lang.RuntimeException: non-nullable field authBytes was serialized as null #3597

nitin1677 · 2023-03-31T02:28:33Z

nitin1677
Mar 31, 2023

trying to use provectuslabs/kafka-ui:master to monitor azure event hub.

Currently we are using kafdrop and working fine with azure event hub.

But kafka-ui is not able to connect azure event hub with error as:
java.lang.RuntimeException: non-nullable field authBytes was serialized as null

Error Stack:
2023-03-30 20:55:08,262 WARN [kafka-admin-client-thread | kafka-ui-admin-1680209706-1] o.a.k.c.n.Selector: [AdminClient clientId=kafka-ui-admin-1680209706-1] Unexpected error from .servicebus.windows.net/00.000.000.00 (channelId=-1); closing connection
java.lang.RuntimeException: non-nullable field authBytes was serialized as null
        at org.apache.kafka.common.message.SaslAuthenticateResponseData.read(SaslAuthenticateResponseData.java:137)
        at org.apache.kafka.common.message.SaslAuthenticateResponseData.(SaslAuthenticateResponseData.java:86)
        at org.apache.kafka.common.requests.SaslAuthenticateResponse.parse(SaslAuthenticateResponse.java:81)
        at org.apache.kafka.common.requests.AbstractResponse.parseResponse(AbstractResponse.java:187)
        at org.apache.kafka.common.requests.AbstractResponse.parseResponse(AbstractResponse.java:109)
        at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:729)
        at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:576)
        at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveToken(SaslClientAuthenticator.java:508)
        at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:302)
        at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181)
        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:560)
        at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1415)
        at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1346)

Yaml file for docker-compose as:

version: '2'

services:
kafka-ui:
    image: provectuslabs/kafka-ui:master
    container_name: kafka-ui
    ports:
      - "8080:8081"
    restart: always
    environment:
      - KAFKA_CLUSTERS_0_NAME=azure-event-hub
      - GROUP_ID=$Default
      - REQUEST_TIMEOUT_MS=60000
      - KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL=SASL_SSL
      - KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=.servicebus.windows.net:9093
      - KAFKA_CLUSTERS_0_PROPERTIES_SASL_MECHANISM=PLAIN
      - KAFKA_CLUSTERS_0_PROPERTIES_SASL_JAAS_CONFIG=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password='Endpoint=sb://.servicebus.windows.net/;SharedAccessKeyName=-producer-authrule;SharedAccessKey=';