You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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:
confluent-kafka-go and librdkafka version (LibraryVersion()): v2.5.3
The text was updated successfully, but these errors were encountered:
xyz5881
changed the title
NewConfigWithBearerAuthentication BearerAuthCredentialsSource using STATIC_TOKEN
NewConfigWithBearerAuthentication BearerAuthCredentialsSource using STATIC_TOKEN, after token expire, schema registry not work
Sep 24, 2024
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)
The text was updated successfully, but these errors were encountered: