| commit | 45378bdeac90364555739507951ac64832e0ded3 | [log] [tgz] |
|---|---|---|
| author | Kamil Trysiński <kamilkime@pm.me> | Tue Oct 07 21:06:05 2025 +0200 |
| committer | GitHub <noreply@github.com> | Tue Oct 07 15:06:05 2025 -0400 |
| tree | ea2188cde86768b54b4fdf2b765c7b73db1e8b04 | |
| parent | 157ebb2327d53935812133918779f0b02f557d8f [diff] |
Properly migrate properties in classes extending SchemaRegistryRecordSetWriter (#10403)
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java index d3a3932..a554f0d 100644 --- a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java +++ b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java
@@ -106,6 +106,7 @@ @Override public void migrateProperties(final PropertyConfiguration propertyConfiguration) { + super.migrateProperties(propertyConfiguration); propertyConfiguration.removeProperty(OBSOLETE_SCHEMA_PROTOCOL_VERSION); final Optional<String> schemaWriteStrategyFound = propertyConfiguration.getPropertyValue(SCHEMA_WRITE_STRATEGY);