Skip to content

Commit fcfc527

Browse files
authored
Ensure normalize.schemas config is passed during Protobuf ref lookup (#2214)
* Ensure normalize.schemas config is passed during Protobuf ref lookup * Minor fixes * Fix style
1 parent e458f58 commit fcfc527

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

src/confluent_kafka/schema_registry/_async/protobuf.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -381,9 +381,9 @@ async def _resolve_dependencies(
381381
subject = self._ref_reference_subject_func(ctx, dep)
382382
schema = Schema(_schema_to_str(dep), references=dep_refs, schema_type='PROTOBUF')
383383
if self._auto_register:
384-
await self._registry.register_schema(subject, schema)
384+
await self._registry.register_schema(subject, schema, normalize_schemas=self._normalize_schemas)
385385

386-
reference = await self._registry.lookup_schema(subject, schema)
386+
reference = await self._registry.lookup_schema(subject, schema, normalize_schemas=self._normalize_schemas)
387387
# schema_refs are per file descriptor
388388
schema_refs.append(SchemaReference(dep.name, subject, reference.version))
389389
return schema_refs

src/confluent_kafka/schema_registry/_sync/protobuf.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -377,9 +377,9 @@ def _resolve_dependencies(self, ctx: SerializationContext, file_desc: FileDescri
377377
subject = self._ref_reference_subject_func(ctx, dep)
378378
schema = Schema(_schema_to_str(dep), references=dep_refs, schema_type='PROTOBUF')
379379
if self._auto_register:
380-
self._registry.register_schema(subject, schema)
380+
self._registry.register_schema(subject, schema, normalize_schemas=self._normalize_schemas)
381381

382-
reference = self._registry.lookup_schema(subject, schema)
382+
reference = self._registry.lookup_schema(subject, schema, normalize_schemas=self._normalize_schemas)
383383
# schema_refs are per file descriptor
384384
schema_refs.append(SchemaReference(dep.name, subject, reference.version))
385385
return schema_refs

0 commit comments

Comments
 (0)