Skip to content

Commit c3cec41

Browse files
jekelrayokota
andauthored
Set registered schema subject correctly (confluentinc#2020)
* Set registered schema subject correctly * Run python tools/unasync.py --------- Co-authored-by: Robert Yokota <[email protected]>
1 parent 765795c commit c3cec41

File tree

2 files changed

+18
-2
lines changed

2 files changed

+18
-2
lines changed

src/confluent_kafka/schema_registry/_async/schema_registry_client.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -645,7 +645,15 @@ async def register_schema_full_response(
645645
'subjects/{}/versions?normalize={}'.format(_urlencode(subject_name), normalize_schemas),
646646
body=request)
647647

648-
registered_schema = RegisteredSchema.from_dict(response)
648+
result = RegisteredSchema.from_dict(response)
649+
650+
registered_schema = RegisteredSchema(
651+
schema_id=result.schema_id,
652+
guid=result.guid,
653+
subject=result.subject or subject_name,
654+
version=result.version,
655+
schema=result.schema,
656+
)
649657

650658
# The registered schema may not be fully populated
651659
s = registered_schema.schema if registered_schema.schema.schema_str is not None else schema

src/confluent_kafka/schema_registry/_sync/schema_registry_client.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -645,7 +645,15 @@ def register_schema_full_response(
645645
'subjects/{}/versions?normalize={}'.format(_urlencode(subject_name), normalize_schemas),
646646
body=request)
647647

648-
registered_schema = RegisteredSchema.from_dict(response)
648+
result = RegisteredSchema.from_dict(response)
649+
650+
registered_schema = RegisteredSchema(
651+
schema_id=result.schema_id,
652+
guid=result.guid,
653+
subject=result.subject or subject_name,
654+
version=result.version,
655+
schema=result.schema,
656+
)
649657

650658
# The registered schema may not be fully populated
651659
s = registered_schema.schema if registered_schema.schema.schema_str is not None else schema

0 commit comments

Comments
 (0)