ruanwenjun edited a comment on issue #1461: URL: https://github.com/apache/incubator-seatunnel/issues/1461#issuecomment-1064037104
I am also newly in seatunnel and flink, I think this feature might be interesting and useful. The current `seatunnel-connector-flink-jdbc` is just used for offline batch job, it doesn't support realtime capture the data change of database. And `flink-cdc` is good at capturing the data change, if we add flink-cdc into seatunnel, this can help seatunnel do the realtime capture job. And I try to answer your concern: 1. I think is ok to transform sourcerecord into JSON, 2. This depends on which system we want to sink, if we want to sink into database we can just use SQL, if we want to into other system like kafka, we can use clienk. I think the `flink-cpc` is also focus on get the data change event, it doesn't care about how to use the change event. 3. I am not sure the license if the license is allowed, this may depend on whether the binary contains mysql-connector This is a good begin, wait for other community member give more suggestions. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
