Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18705

Debezium-JSON throws NPE when tombstone message is received

    XMLWordPrintableJSON

    Details

      Description

      By default, Debezium will send two messages to Kafka for DELETE operation, one for delete message, the other for tombstone message (message value is null). However, debezium-json will throw NPE when processing such tombstone message. We should just skip such messages.

      As a workaround, we can diable tombstone on Debezium Connect tombstones.on.delete: false.

        Attachments

          Activity

            People

            • Assignee:
              jark Jark Wu
              Reporter:
              jark Jark Wu
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: