[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:
Documented
Duplicate
duplicates KAFKA-131 Copy existing configuration with pipe... Closed
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 ]

Hi feys1992@gmail.com,

 
Thanks for the ticket - this a duplicate of KAFKA-131 and this feature will be released in the next release 1.3.0

Ross

Generated at Thu Feb 08 09:05:42 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.