Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
3.10.0
-
None
-
Unknown
Description
Although streamFilter is declared as a UriParam: https://github.com/apache/camel/blob/main/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java#L108 (it should be annotated as consumer only though)
it is not honored. Such filter is only loaded from property: https://github.com/apache/camel/blob/main/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsConsumer.java#L60-L64
as reported in ckc issue: https://github.com/apache/camel-kafka-connector/issues/1112