Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-4746

ConfluentSchemaRegistry Controller service only uses latest schema, failing if schema changed

    Details

    • Flags:
      Important

      Description

      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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              adfeldev AdFel
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: