MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

apache · Apr 29, 2022 · 42f931c · 42f931c
1 parent 8b90d13
commit 42f931c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ary/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml b/...ary/camel-kamelets/src/main/resources/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: {}