From c265afb67bf838f16accc151a7c48fd5e2960796 Mon Sep 17 00:00:00 2001 From: Jekel Date: Wed, 13 Aug 2025 21:17:35 +0300 Subject: [PATCH 1/2] Set registered schema subject correctly --- .../schema_registry/_async/schema_registry_client.py | 10 +++++++++- .../schema_registry/_sync/schema_registry_client.py | 11 ++++++++++- 2 files changed, 19 insertions(+), 2 deletions(-) diff --git a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py index 77a10ef27..11dd39a69 100644 --- a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py @@ -645,7 +645,15 @@ async def register_schema_full_response( 'subjects/{}/versions?normalize={}'.format(_urlencode(subject_name), normalize_schemas), body=request) - registered_schema = RegisteredSchema.from_dict(response) + result = RegisteredSchema.from_dict(response) + + registered_schema = RegisteredSchema( + schema_id=result.schema_id, + guid=result.guid, + subject=result.subject or subject_name, + version=result.version, + schema=result.schema, + ) # The registered schema may not be fully populated s = registered_schema.schema if registered_schema.schema.schema_str is not None else schema diff --git a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py index 060c541c4..a25d325dd 100644 --- a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py @@ -645,7 +645,16 @@ def register_schema_full_response( 'subjects/{}/versions?normalize={}'.format(_urlencode(subject_name), normalize_schemas), body=request) - registered_schema = RegisteredSchema.from_dict(response) + result = RegisteredSchema.from_dict(response) + + registered_schema = RegisteredSchema( + schema_id=result.schema_id, + guid=result.guid, + subject=result.subject or subject_name, + version=result.version, + schema=result.schema, + ) + # The registered schema may not be fully populated s = registered_schema.schema if registered_schema.schema.schema_str is not None else schema From 2f14cbecdf75a9d3487170fa99970bfdb6a09ca6 Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Wed, 13 Aug 2025 15:03:35 -0700 Subject: [PATCH 2/2] Run python tools/unasync.py --- .../schema_registry/_sync/schema_registry_client.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py index a25d325dd..512f44592 100644 --- a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py @@ -655,7 +655,6 @@ def register_schema_full_response( schema=result.schema, ) - # The registered schema may not be fully populated s = registered_schema.schema if registered_schema.schema.schema_str is not None else schema self._cache.set_schema(subject_name, registered_schema.schema_id,