[KAFKA-150] When copy exist, support config pipeline before default replaceRoot pipeline Created: 28/Aug/20 Updated: 16/Sep/20 Resolved: 16/Sep/20 |
|
| Status: | Closed |
| Project: | Kafka Connector |
| Component/s: | Source |
| Affects Version/s: | 1.2.0 |
| Fix Version/s: | 1.3.0 |
| Type: | Improvement | Priority: | Major - P3 |
| Reporter: | 杰 王 | Assignee: | Ross Lawley |
| Resolution: | Duplicate | Votes: | 0 |
| Labels: | None | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Issue Links: |
|
||||||||||||
| Documentation Changes: | Needed | ||||||||||||
| Description |
|
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?
|
| Comments |
| Comment by Ross Lawley [ 16/Sep/20 ] |
|
Ross |