Hi Team,
I am creating one kafka-golang client. This client is trying to get the token from IAM using “oidc” oauthbearer method in order to establish a secure connection with kafka. Also using “librdkafka” dependency. I am using below config:
bootstrap.servers=kafka-bootstrap:9095
security.protocol=SASL_SSL
sasl.mechanism=OAUTHBEARER
ssl.ca.location=/var/tmp/go/ca.pem
ssl.certificate.location=/var/tmp/go/clicert.pem
ssl.key.location=/var/tmp/go/cliprivkey.pem
ssl.key.password=password
sasl.oauthbearer.method=oidc
sasl.oauthbearer.scope=openid
sasl.oauthbearer.client.id=client-oauth2
sasl.oauthbearer.client.secret=xxxxxxxxxxxxxxxxxxxxxxxxx
sasl.oauthbearer.token.endpoint.url=https://xxxxxxxxxxx:8443/auth/realms/master/protocol/openid-connect/token
I am getting below error:
Kindly help me here.
Thanks,
Amir