Using oauthClientId and oauthSecretId to generate the oauthToken and pass the value to NewConfigWithBearerAuthentication, then set up the schemaRegistryClient. After the oauthToken is expired, the schemaRegistryClient also expired. Hope there is a way to pass in clientid and secret, or it's hard to refresh schemaRegistry every time when we get a new token - since it's set as STATIC_TOKEN
Checklist
Please provide the following information:
[x] confluent-kafka-go and librdkafka version (LibraryVersion()): v2.5.3
Description
How to reproduce
Using oauthClientId and oauthSecretId to generate the oauthToken and pass the value to NewConfigWithBearerAuthentication, then set up the schemaRegistryClient. After the oauthToken is expired, the schemaRegistryClient also expired. Hope there is a way to pass in clientid and secret, or it's hard to refresh schemaRegistry every time when we get a new token - since it's set as STATIC_TOKEN
Checklist
Please provide the following information:
LibraryVersion()): v2.5.3_ = configMap.SetKey(keySecurityProtocol, securityProtocolSaslSsl) _ = configMap.SetKey(keySaslMechanism, saslMechanismOAuthBearer) _ = configMap.SetKey(keySaslOAuthClientID, clientID) _ = configMap.SetKey(keySaslOAuthClientSecret, clientSecret) _ = configMap.SetKey(keySaslOAuthTokenEndpointURL, tokenURL) _ = configMap.SetKey(keySaslOAuthMethod, saslOAuthBearerMethodOIDC) _ = configMap.SetKey(keySaslOAuthScope, saslOAuthBearerScopeUser) _ = configMap.SetKey(keySaslOAuthExtensions, fmt.Sprintf("%s=%s,%s=%s", optionLogicalCluster, clusterID, optionIdentityPoolID, identityPoolID))"debug": ".."as necessary)error: schema registry request failed error code: 401: Unauthorized](error: schema registry request failed error code: 401: Unauthorized)