[camel-kamelets] 01/02: MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch stream-filter
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit e33cb6bb88ae44a2c46a643b2861256ab5c9fe51
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 29 14:48:26 2022 +0200

    MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter
---
 kamelets/mongodb-changes-stream-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/mongodb-changes-stream-source.kamelet.yaml b/kamelets/mongodb-changes-stream-source.kamelet.yaml
index a5f4e025..3095dfcd 100644
--- a/kamelets/mongodb-changes-stream-source.kamelet.yaml
+++ b/kamelets/mongodb-changes-stream-source.kamelet.yaml
@@ -63,6 +63,11 @@ spec:
         title: MongoDB Database
         description: Sets the name of the MongoDB database to target.
         type: string
+      streamFilter:
+        title: Stream Filter
+        description: Filter condition for change streams consumer.
+        type: string
+        example: "{ '$match':{'$or':[{'fullDocument.stringValue': 'specificValue'}]} }"
   dependencies:
     - "camel:kamelet"
     - "camel:mongodb"
@@ -80,6 +85,7 @@ spec:
         username: "{{?username}}"
         database: "{{database}}"
         consumerType: "changeStreams"
+        streamFilter: "{{?streamFilter}}"
       steps:
       - marshal:
           json: {}