fails to deserialise avro messages

[rsurenderreddy]

Hi,

I am trying to deserialize Avro messages with the glue registry. It's not decoding, can you help here.

Here is the docker file:

version: '3'
services:
kafka-ui:
container_name: kafka-ui
image: provectuslabs/kafka-ui
ports:
- 443:8443
healthcheck:
test: wget --no-check-certificate --no-verbose --tries=1 --spider https://localhost:8443/actuator/health
interval: 30s
timeout: 10s
retries: 10
environment:
DYNAMIC_CONFIG_ENABLED: true
JAVA_OPTS: "-Xms1g -Xmx3g"
volumes:
- /apps/config/dynamic_config.yaml:/etc/kafkaui/dynamic_config.yaml
- /apps/ssl/kafka.keystore.jks:/kafka.keystore.jks
- /apps/ssl/kafka.truststore.jks:/kafka.truststore.jks
- /apps/config/roles.yaml:/roles.yaml
- /apps/config/glue/kafkaui-glue-serde-v1.2.1-jar-with-dependencies.jar:/kafkaui-glue-serde-v1.2.1-jar-with-dependencies.jar
restart: always

Dynamic Config:

kafka:
clusters:
- name: kafka-cluster
bootstrapServers: "b-2.dev-kafka-clu.fm3yky.c14.kafka.us-east-1.amazonaws.com:9098,b-1.dev-kafka-clu.fm3yky.c14.kafka.us-east-1.amazonaws.com:9098"
properties:
security.protocol: SASL_SSL
sasl.mechanism: AWS_MSK_IAM
sasl.client.callback.handler.class: software.amazon.msk.auth.iam.IAMClientCallbackHandler
sasl.jaas.config: software.amazon.msk.auth.iam.IAMLoginModule required;
serde:
name: GlueSchemaRegistry
filePath: /kafkaui-glue-serde-v1.2.1-jar-with-dependencies.jar
className: com.provectus.kafka.ui.serdes.glue.GlueSerde
properties:
region: us-east-1 #required
registry: qa1.bjs-digital-schema-registry #required, name of Glue Schema Registry
topicKeysSchemas:
class org.apache.kafka.common.serialization.StringDeserializer
topicValuesSchemas:
class com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryKafkaDeserializer
keySchemaNameTemplate: '%s-key'
valueSchemaNameTemplate: '%s-value'

Here is the admin config values, during ui startup:
allow.auto.create.topics = false
[kafka-ui] | auto.commit.interval.ms = 5000
[kafka-ui] | auto.offset.reset = earliest
[kafka-ui] | bootstrap.servers = [b-2.dev-kafka-clu.fm3yky.c14.kafka.us-east-1.amazonaws.com:9098, b-1.dev-kafka-clu.fm3yky.c14.kafka.us-east-1.amazonaws.com:9098]
[kafka-ui] | check.crcs = true
[kafka-ui] | client.dns.lookup = use_all_dns_ips
[kafka-ui] | client.id = kafka-ui-consumer-1698431268448
[kafka-ui] | client.rack =
[kafka-ui] | connections.max.idle.ms = 540000
[kafka-ui] | default.api.timeout.ms = 60000
[kafka-ui] | enable.auto.commit = false
[kafka-ui] | exclude.internal.topics = true
[kafka-ui] | fetch.max.bytes = 52428800
[kafka-ui] | fetch.max.wait.ms = 500
[kafka-ui] | fetch.min.bytes = 1
[kafka-ui] | group.id = null
[kafka-ui] | group.instance.id = null
[kafka-ui] | heartbeat.interval.ms = 3000
[kafka-ui] | interceptor.classes = []
[kafka-ui] | internal.leave.group.on.close = true
[kafka-ui] | internal.throw.on.fetch.stable.offset.unsupported = false
[kafka-ui] | isolation.level = read_uncommitted
[kafka-ui] | key.deserializer = class org.apache.kafka.common.serialization.BytesDeserializer
[kafka-ui] | max.partition.fetch.bytes = 1048576
[kafka-ui] | max.poll.interval.ms = 300000
[kafka-ui] | max.poll.records = 500
[kafka-ui] | metadata.max.age.ms = 300000
[kafka-ui] | metric.reporters = []
[kafka-ui] | metrics.num.samples = 2
[kafka-ui] | metrics.recording.level = INFO
[kafka-ui] | metrics.sample.window.ms = 30000
[kafka-ui] | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
[kafka-ui] | receive.buffer.bytes = 65536
[kafka-ui] | reconnect.backoff.max.ms = 1000
[kafka-ui] | reconnect.backoff.ms = 50
[kafka-ui] | request.timeout.ms = 30000
[kafka-ui] | retry.backoff.ms = 100
[kafka-ui] | sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
[kafka-ui] | sasl.jaas.config = [hidden]
[kafka-ui] | sasl.kerberos.kinit.cmd = /usr/bin/kinit
[kafka-ui] | sasl.kerberos.min.time.before.relogin = 60000
[kafka-ui] | sasl.kerberos.service.name = null
[kafka-ui] | sasl.kerberos.ticket.renew.jitter = 0.05
[kafka-ui] | sasl.kerberos.ticket.renew.window.factor = 0.8
[kafka-ui] | sasl.login.callback.handler.class = null
[kafka-ui] | sasl.login.class = null
[kafka-ui] | sasl.login.connect.timeout.ms = null
[kafka-ui] | sasl.login.read.timeout.ms = null
[kafka-ui] | sasl.login.refresh.buffer.seconds = 300
[kafka-ui] | sasl.login.refresh.min.period.seconds = 60
[kafka-ui] | sasl.login.refresh.window.factor = 0.8
[kafka-ui] | sasl.login.refresh.window.jitter = 0.05
[kafka-ui] | sasl.login.retry.backoff.max.ms = 10000
[kafka-ui] | sasl.login.retry.backoff.ms = 100
[kafka-ui] | sasl.mechanism = AWS_MSK_IAM
[kafka-ui] | sasl.oauthbearer.clock.skew.seconds = 30
[kafka-ui] | sasl.oauthbearer.expected.audience = null
[kafka-ui] | sasl.oauthbearer.expected.issuer = null
[kafka-ui] | sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
[kafka-ui] | sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
[kafka-ui] | sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
[kafka-ui] | sasl.oauthbearer.jwks.endpoint.url = null
[kafka-ui] | sasl.oauthbearer.scope.claim.name = scope
[kafka-ui] | sasl.oauthbearer.sub.claim.name = sub
[kafka-ui] | sasl.oauthbearer.token.endpoint.url = null
[kafka-ui] | security.protocol = SASL_SSL
[kafka-ui] | security.providers = null
[kafka-ui] | send.buffer.bytes = 131072
[kafka-ui] | session.timeout.ms = 45000
[kafka-ui] | socket.connection.setup.timeout.max.ms = 30000
[kafka-ui] | socket.connection.setup.timeout.ms = 10000
[kafka-ui] | ssl.cipher.suites = null
[kafka-ui] | ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
[kafka-ui] | ssl.endpoint.identification.algorithm = https
[kafka-ui] | ssl.engine.factory.class = null
[kafka-ui] | ssl.key.password = null
[kafka-ui] | ssl.keymanager.algorithm = SunX509
[kafka-ui] | ssl.keystore.certificate.chain = null
[kafka-ui] | ssl.keystore.key = null
[kafka-ui] | ssl.keystore.location = /kafka.keystore.jks
[kafka-ui] | ssl.keystore.password = [hidden]
[kafka-ui] | ssl.keystore.type = JKS
[kafka-ui] | ssl.protocol = TLSv1.3
[kafka-ui] | ssl.provider = null
[kafka-ui] | ssl.secure.random.implementation = null
[kafka-ui] | ssl.trustmanager.algorithm = PKIX
[kafka-ui] | ssl.truststore.certificates = null
[kafka-ui] | ssl.truststore.location = /kafka.truststore.jks
[kafka-ui] | ssl.truststore.password = [hidden]
[kafka-ui] | ssl.truststore.type = JKS
[kafka-ui] | value.deserializer = class org.apache.kafka.common.serialization.BytesDeserialize