Details
-
Bug
-
Resolution: Done
-
Minor
-
0.6.2
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