search

Aiven-Open / klaw

Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/authorizations to users of various teams of an org.
https://www.klaw-project.io/
Apache License 2.0
151 stars 60 forks source link

Unable to fetch messages from Aiven with Azure #2504

Open maciejmaciejko-gid opened 5 months ago

maciejmaciejko-gid commented 5 months ago

What happened?

I can not fetch messages from kafka topic in Klaw.

What did you expect to happen?

Messages should be fetched and displayed correctly (e.g. avro format).

What else do we need to know?

Klaw 2.9.0, Aiven cluster with SASL_SSL_SCRAM_MECHANISM_256, Kafka cluster in Azure. I tried with different types of messages (avro, binary etc)

Exception: klaw-cluster-api | java.io.EOFException: null klaw-cluster-api | at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:109) ~[kafka-clients-3.7.0.jar!/:na] klaw-cluster-api | at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452) ~[kafka-clients-3.7.0.jar!/:na] klaw-cluster-api | at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402) ~[kafka-clients-3.7.0.jar!/:na] klaw-cluster-api | at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674) ~[kafka-clients-3.7.0.jar!/:na] klaw-cluster-api | at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576) ~[kafka-clients-3.7.0.jar!/:na]

muralibasani commented 5 months ago

@maciejmaciejko-gid did you try configuring a consumer group in cluster api config ? klaw.topiccontents.consumergroup.id