henneberger opened a new pull request, #3562: URL: https://github.com/apache/flink-cdc/pull/3562
Adds the option to do an insert-only stream for connectors that support specifying a changelog mode. This allows debezium connectors to be imported into flink as stream tables to take advantage of flink's strong stream processing capabilities. There is currently no way to convert a all/upsert changelog stream to an insert-only stream with just the flink table api so this appears to be the only workaround. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
