Skip to content

Instantly share code, notes, and snippets.

@ngollperrier

ngollperrier/kafka-connect-leboncoin-config-example-part-04.json

Created April 23, 2021 17:04
Show Gist options
  • Save ngollperrier/d65244681d0388e224adcc6d534223e1 to your computer and use it in GitHub Desktop.
Save ngollperrier/d65244681d0388e224adcc6d534223e1 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka-connect-leboncoin-config-example-part-04.json
"transforms": "tombstoneHandler,insertFields",
"transforms.tombstoneHandler.type": "io.confluent.connect.transforms.TombstoneHandler",
"transforms.tombstoneHandler.behavior": "ignore",
"transforms.insertFields.type": "org.apache.kafka.connect.transforms.InsertField$Value",
"transforms.insertFields.partition.field": "_kafka_partition",
"transforms.insertFields.offset.field": "_kafka_offset",
"transforms.insertFields.timestamp.field": "_kafka_timestamp",
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment