You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Pierre Villard (Jira)" <ji...@apache.org> on 2026/01/05 10:41:00 UTC
[jira] [Updated] (NIFI-4746) ConfluentSchemaRegistry Controller service only uses latest schema, failing if schema changed
[ https://issues.apache.org/jira/browse/NIFI-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pierre Villard updated NIFI-4746:
---------------------------------
Resolution: Feedback Received
Status: Resolved (was: Patch Available)
Apache NiFi 1.x is no longer maintained and no new release is planned on the 1.x release line. Marking as resolved as part of a cleanup operation. Please open a new one with an updated description if this is still relevant for NiFi 2.x.
> ConfluentSchemaRegistry Controller service only uses latest schema, failing if schema changed
> ---------------------------------------------------------------------------------------------
>
> Key: NIFI-4746
> URL: https://issues.apache.org/jira/browse/NIFI-4746
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.4.0
> Reporter: AdFel
> Priority: Major
> Labels: confluent-kafka, confluentic, schema
> Attachments: 0001-get-schema-by-id-and-cache.patch
>
>
> When ConsumeKafkaRecord_01X uses the ConfluentSchemaRegistry 1.4.0 the id in the magic byte is not used to merge the latest schema with the writer schema, as stated in the Apache Avro documentation. Nifi instead compares the id to the latest schema's ID, and if they do not match, the flowfile is sent to the parse.failure. To fix this bug the ConfluentSchemaRegistry controller should merge the writer's schema with the latest schema, using the ID written in the magic byte
--
This message was sent by Atlassian Jira
(v8.20.10#820010)