From 42f931c6f32db757ffece0b05e9f9e811686621c Mon Sep 17 00:00:00 2001
From: Andrea Cosentino <ancosen@gmail.com>
Date: Fri, 29 Apr 2022 14:49:28 +0200
Subject: [PATCH] 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/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml
index a5f4e0258..3095dfcd9 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml
+++ b/library/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: {}