From d0d70959c08d7be031e738526a9c7b6bd772546f Mon Sep 17 00:00:00 2001 From: Tom Blench Date: Wed, 17 Aug 2022 15:04:00 +0100 Subject: [PATCH 1/2] Update README.md Co-authored-by: Rich Ellis --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 39a9d8f..50e3b53 100644 --- a/README.md +++ b/README.md @@ -80,7 +80,7 @@ Single Message Transforms, or SMTs, can be used to customize fields or values of ``` 1. If you have events where there is no value ([_tombstone_ events](https://kafka.apache.org/documentation.html#compaction)), you may wish to filter these out. - In the Cloudant sink connector, these may be undesirable as they will generate an empty document. - - In the Cloudant source connector, tombstone events are generated by default for deleted documents (in addition to the deleted document itself). + - In the Cloudant source connector, tombstone events are generated for deleted documents (in addition to the deleted document itself). - In either case, you will need to use a `dropNullRecords` transform and predicate to filter out and remove these tombstone events: ``` From 2c431905a8f3038bcb8325940503d7d0919efb2c Mon Sep 17 00:00:00 2001 From: Tom Blench Date: Wed, 17 Aug 2022 15:04:07 +0100 Subject: [PATCH 2/2] Update README.md Co-authored-by: Rich Ellis --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 50e3b53..2941b80 100644 --- a/README.md +++ b/README.md @@ -81,7 +81,7 @@ Single Message Transforms, or SMTs, can be used to customize fields or values of 1. If you have events where there is no value ([_tombstone_ events](https://kafka.apache.org/documentation.html#compaction)), you may wish to filter these out. - In the Cloudant sink connector, these may be undesirable as they will generate an empty document. - In the Cloudant source connector, tombstone events are generated for deleted documents (in addition to the deleted document itself). - - In either case, you will need to use a `dropNullRecords` transform and predicate to filter out and remove these tombstone events: + - In either case, you can use the `RecordIsTombstone` predicate with a filter to remove these tombstone events as shown in this example: ``` transforms=dropNullRecords