From 6e1f26273e4afe1670e1fb15d28a57ccfcfbebc4 Mon Sep 17 00:00:00 2001 From: "Quentin R. Voglund" Date: Fri, 7 Mar 2025 13:50:22 -0600 Subject: [PATCH 1/2] move tkoen --- src/confluent_kafka/schema_registry/schema_registry_client.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/confluent_kafka/schema_registry/schema_registry_client.py b/src/confluent_kafka/schema_registry/schema_registry_client.py index 0e301e73d..31ca6cc48 100644 --- a/src/confluent_kafka/schema_registry/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/schema_registry_client.py @@ -299,9 +299,11 @@ def __init__(self, conf: dict): ) def handle_bearer_auth(self, headers: dict): - token = self.bearer_token if self.oauth_client: token = self.oauth_client.get_access_token() + else: + token = self.bearer_token + headers["Authorization"] = "Bearer {}".format(token) headers['Confluent-Identity-Pool-Id'] = self.identity_pool_id headers['target-sr-cluster'] = self.logical_cluster From c3d956d7676ed3c3c7484f097e01f2d65df00ddc Mon Sep 17 00:00:00 2001 From: "Quentin R. Voglund" Date: Fri, 7 Mar 2025 13:55:42 -0600 Subject: [PATCH 2/2] associating email