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

JDBC Connector is lost when filter.include.list is used

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 3.2.0.CR1
    • None
    • jdbc-connector
    • None
    • False
    • Hide

      None

      Show
      None
    • False

      https://github.com/debezium/debezium/blob/main/debezium-sink/src/main/java/io/debezium/bindings/kafka/KafkaDebeziumSinkRecord.java#L315

      data.get(field) do a lookup by id behind the scene. But the schema can be different when we filter, so id do not match.

      We should do data.get(field.name())

              Unassigned Unassigned
              bertrand.paquet@gmail.com Bertrand Paquet
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: