Schema Registry giving 401 error

[shankar0909]

I am submitting the Hazelcast jet job written in Java to AKS pods. The job will process Avro events and connect to confluent Kafka topic and schema registry. I am using SASL_SSL via JASS configuration for confluent kafka connection and USER_INFO for SR. I have validated all the configs (Properties) in AKS pods and all seems to correct. As soon as job starts and starts processing event, it fails with 401 error while connecting to Schema Registry. I have tried all configs combinations possible mentioned over the articles/stackoverflow etc. Any suggestions ?

bootstrap.servers=........confluent.cloud:9092
key.serializer=org.apache.kafka.common.serialization
value.serializer=io.confluent.kafka.serializers.KafkaAvroSerializer
schema.registry.url=https://....confluent.cloud
basic.auth.credentials.source=USER_INFO
basic.auth.user.info=key:secret

security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="" password="";

!-- I have tried using below combination as well but didn't work
schema.registry.basic.auth.credentials.source=USER_INFO
schema.registry.basic.auth.user.info=key:secret

Using all latest libraries in this spring Autorunner app via pom.xml.

• Hazelcast dependencies version: 5.5.0 [In AKS pods Hazelcast version is 5.5.6]
• Confluent dependency version: 8.0.0
• Avro dependency version: 1.12.0