[GitHub] [camel] yingbo-wu commented on pull request #2960: CAMEL-12481: Add Change Streams support to MongoDB component

[GitBox]

yingbo-wu commented on pull request #2960:
URL: https://github.com/apache/camel/pull/2960#issuecomment-802478314


   org/apache/camel/component/mongodb3/MongoDbChangeStreamsConsumer.java
   
   ```
   String streamFilter = (String) 
getRoute().getProperties().get(STREAM_FILTER_PROPERTY);
   List<BsonDocument> bsonFilter = null;
   if (ObjectHelper.isNotEmpty(streamFilter)) {
       bsonFilter = singletonList(BsonDocument.parse(streamFilter));
   }
   ```
   When set configuration: **camel.source.endpoint.streamFilter**
   Invalid while using **camel-mongodb-kafka-connector**
   Even setting an incorrect JSON format will not cause any exceptions
   
   My guess is that the code is incompatible this time "**String streamFilter = 
(String) getRoute().getProperties().get(STREAM_FILTER_PROPERTY);**"
   
   Should we switch to this way?: "**String streamFilter = 
endpoint.getStreamFilter();**"
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org