When i use mongo kafka connector, I need to copy part existing data. The filter like this:
``{$match: {$gt:
{created_at: ISODate(xxx)}}}``.
When copy existing data, we have default pipeline: replaceRoot. All pipeline added by config will add after this default pipeline.
Can we support add before this default pipeline?
- duplicates
-
KAFKA-131 Copy existing configuration with pipeline
-
- Closed
-