You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had thought that a pipeline mysql is only for a snapshot,
but when I put the data into mysql, my kafka-sink got real time updated data.
So now I am very confused, what's the difference between those.
Can anyone explain what's the purpose of those two?
Does pipeline mysql connector also doing CDC job (there are option debezium on yaml file)?
Then why there is also a source mysql-cdc connector?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Hello, thanks for the nice software.
I am trying to use a flink cdc and have found out there are two mysql connectors.
pipeline: https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/connectors/pipeline-connectors/mysql/
source: https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/connectors/flink-sources/mysql-cdc/
I had thought that a pipeline mysql is only for a snapshot,
but when I put the data into mysql, my kafka-sink got real time updated data.
So now I am very confused, what's the difference between those.
Can anyone explain what's the purpose of those two?
Does pipeline mysql connector also doing CDC job (there are option debezium on yaml file)?
Then why there is also a source mysql-cdc connector?
Beta Was this translation helpful? Give feedback.
All reactions