Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-466

Hardcoded schema version overrides schema registry version

    XMLWordPrintable

Details

    Description

      I am working with Debezium MySQL Connector and Confluent's Schema Registry and AvroConverter. I'd like to use the schema version of Kafka Connect records in my custom Kafka Connect extensions (e.g. transformations, partitioners).

      The version that schema registry provides would be perfect for this and in theory I could access it from my code like connectRecord.valueSchema().version(). Unfortunately the version provided in schema registry gets "overridden" by Debezium with a constant value of 1.

      See discussion on https://groups.google.com/forum/#!topic/debezium/Tw8JG5u1p7o

      Attachments

        Activity

          People

            Unassigned Unassigned
            david.szabo David Szabo (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: