āĻāĻāĻŋ Apache Flink āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC Connectors āĻ¨āĻžāĻŽā§ āĻāĻāĻāĻŋ āĻ˛āĻŋāĻ¨āĻžāĻā§āĻ¸ āĻ ā§āĻ¯āĻžāĻĒ āĻ¯āĻžāĻ° āĻ¸āĻ°ā§āĻŦāĻļā§āĻˇ āĻ°āĻŋāĻ˛āĻŋāĻāĻāĻŋ Release-2.4.1.zip āĻšāĻŋāĻ¸āĻžāĻŦā§ āĻĄāĻžāĻāĻ¨āĻ˛ā§āĻĄ āĻāĻ°āĻž āĻ¯ā§āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ āĻāĻāĻŋ āĻāĻ¯āĻŧāĻžāĻ°ā§āĻāĻ¸ā§āĻā§āĻļāĻ¨ā§āĻ° āĻāĻ¨ā§āĻ¯ āĻŦāĻŋāĻ¨āĻžāĻŽā§āĻ˛ā§āĻ¯ā§āĻ° āĻšā§āĻ¸ā§āĻāĻŋāĻ āĻĒā§āĻ°āĻĻāĻžāĻ¨āĻāĻžāĻ°ā§ OnWorks-āĻ āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ā§ āĻāĻžāĻ˛āĻžāĻ¨ā§ āĻ¯ā§āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤
CDC Connectors for Apache Flink with OnWorks āĻ¨āĻžāĻŽā§ āĻāĻ āĻ ā§āĻ¯āĻžāĻĒāĻāĻŋ āĻŦāĻŋāĻ¨āĻžāĻŽā§āĻ˛ā§āĻ¯ā§ āĻĄāĻžāĻāĻ¨āĻ˛ā§āĻĄ āĻāĻ°ā§āĻ¨ āĻāĻŦāĻ āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ā§ āĻāĻžāĻ˛āĻžāĻ¨āĨ¤
āĻāĻ āĻ ā§āĻ¯āĻžāĻĒāĻāĻŋ āĻāĻžāĻ˛āĻžāĻ¨ā§āĻ° āĻāĻ¨ā§āĻ¯ āĻāĻ āĻ¨āĻŋāĻ°ā§āĻĻā§āĻļāĻžāĻŦāĻ˛ā§ āĻ āĻ¨ā§āĻ¸āĻ°āĻŖ āĻāĻ°ā§āĻ¨:
- 1. āĻāĻĒāĻ¨āĻžāĻ° āĻĒāĻŋāĻ¸āĻŋāĻ¤ā§ āĻāĻ āĻ ā§āĻ¯āĻžāĻĒā§āĻ˛āĻŋāĻā§āĻļāĻ¨āĻāĻŋ āĻĄāĻžāĻāĻ¨āĻ˛ā§āĻĄ āĻāĻ°ā§āĻ¨ā§ˇ
- 2. āĻāĻŽāĻžāĻĻā§āĻ° āĻĢāĻžāĻāĻ˛ āĻŽā§āĻ¯āĻžāĻ¨ā§āĻāĻžāĻ°ā§ āĻĒā§āĻ°āĻŦā§āĻļ āĻāĻ°ā§āĻ¨ https://www.onworks.net/myfiles.php?username=XXXXX āĻāĻĒāĻ¨āĻŋ āĻ¯ā§ āĻāĻāĻāĻžāĻ°āĻ¨ā§āĻŽ āĻāĻžāĻ¨āĨ¤
- 3. āĻāĻ āĻ§āĻ°āĻ¨ā§āĻ° āĻĢāĻžāĻāĻ˛ āĻŽā§āĻ¯āĻžāĻ¨ā§āĻāĻžāĻ°ā§ āĻāĻ āĻ ā§āĻ¯āĻžāĻĒā§āĻ˛āĻŋāĻā§āĻļāĻ¨āĻāĻŋ āĻāĻĒāĻ˛ā§āĻĄ āĻāĻ°ā§āĻ¨āĨ¤
- 4. āĻāĻ āĻāĻ¯āĻŧā§āĻŦāĻ¸āĻžāĻāĻ āĻĨā§āĻā§ OnWorks Linux āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ āĻŦāĻž Windows āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ āĻāĻŽā§āĻ˛ā§āĻāĻ° āĻŦāĻž MACOS āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ āĻāĻŽā§āĻ˛ā§āĻāĻ° āĻļā§āĻ°ā§ āĻāĻ°ā§āĻ¨āĨ¤
- 5. OnWorks Linux OS āĻĨā§āĻā§ āĻāĻĒāĻ¨āĻŋ āĻāĻāĻŽāĻžāĻ¤ā§āĻ° āĻļā§āĻ°ā§ āĻāĻ°ā§āĻā§āĻ¨, āĻāĻŽāĻžāĻĻā§āĻ° āĻĢāĻžāĻāĻ˛ āĻŽā§āĻ¯āĻžāĻ¨ā§āĻāĻžāĻ°ā§ āĻ¯āĻžāĻ¨ https://www.onworks.net/myfiles.php?username=XXXXX āĻāĻĒāĻ¨āĻžāĻ° āĻĒāĻāĻ¨ā§āĻĻā§āĻ° āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ°āĻāĻžāĻ°ā§āĻ° āĻ¨āĻžāĻŽ āĻ¸āĻšāĨ¤
- 6. āĻ ā§āĻ¯āĻžāĻĒā§āĻ˛āĻŋāĻā§āĻļāĻ¨āĻāĻŋ āĻĄāĻžāĻāĻ¨āĻ˛ā§āĻĄ āĻāĻ°ā§āĻ¨, āĻāĻāĻŋ āĻāĻ¨āĻ¸ā§āĻāĻ˛ āĻāĻ°ā§āĻ¨ āĻāĻŦāĻ āĻāĻāĻŋ āĻāĻžāĻ˛āĻžāĻ¨āĨ¤
āĻ¸ā§āĻā§āĻ°ā§āĻ¨āĻļāĻāĻā§āĻ˛āĻŋ
Ad
Apache Flink āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§
āĻŦāĻ°ā§āĻŖāĻ¨āĻžāĻ
āĻāĻ āĻĒā§āĻ°āĻā§āĻā§āĻāĻāĻŋ Apache FlinkÂŽ-āĻāĻ° āĻāĻ¨ā§āĻ¯ āĻ¸ā§āĻ°ā§āĻ¸ āĻāĻžāĻ¨ā§āĻā§āĻāĻ°ā§āĻ° āĻāĻāĻāĻŋ āĻ¸ā§āĻ āĻ¸āĻ°āĻŦāĻ°āĻžāĻš āĻāĻ°ā§ āĻ¯āĻž āĻā§āĻā§āĻ āĻĄā§āĻāĻž āĻā§āĻ¯āĻžāĻĒāĻāĻžāĻ° (CDC) āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻŦāĻŋāĻāĻŋāĻ¨ā§āĻ¨ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻĨā§āĻā§ āĻāĻ¸āĻž āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻ¸āĻ°āĻžāĻ¸āĻ°āĻŋ āĻā§āĻ°āĻšāĻŖ āĻāĻ°ā§āĨ¤ Apache FlinkÂŽ āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻāĻžāĻ¨ā§āĻā§āĻāĻ° āĻšāĻ˛ Apache FlinkÂŽ āĻāĻ° āĻāĻ¨ā§āĻ¯ āĻ¸ā§āĻ°ā§āĻ¸ āĻāĻžāĻ¨ā§āĻā§āĻāĻ°ā§āĻ° āĻāĻāĻāĻŋ āĻ¸ā§āĻ, āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨ āĻĄā§āĻāĻž āĻā§āĻ¯āĻžāĻĒāĻāĻžāĻ° (CDC) āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻŦāĻŋāĻāĻŋāĻ¨ā§āĻ¨ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻĨā§āĻā§ āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻā§āĻ°āĻšāĻŖ āĻāĻ°ā§ā§ˇ Apache FlinkÂŽ āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§āĻā§āĻ˛āĻŋ āĻĄā§āĻāĻž āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻā§āĻ¯āĻžāĻĒāĻāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻāĻā§āĻāĻŋāĻ¨ āĻšāĻŋāĻ¸āĻžāĻŦā§ āĻĄā§āĻŦā§āĻāĻŋāĻ¯āĻŧāĻžāĻŽāĻā§ āĻ¸āĻāĻšāĻ¤ āĻāĻ°ā§ā§ˇ āĻ¤āĻžāĻ āĻāĻāĻŋ Debezium āĻāĻ° āĻā§āĻˇāĻŽāĻ¤āĻž āĻ¸āĻŽā§āĻĒā§āĻ°ā§āĻŖāĻ°ā§āĻĒā§ āĻ˛āĻžāĻ āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻ¸ā§āĻ¨ā§āĻ¯āĻžāĻĒāĻļāĻ āĻĒāĻĄāĻŧāĻž āĻ¸āĻŽāĻ°ā§āĻĨāĻ¨ āĻāĻ°ā§ āĻāĻŦāĻ āĻ āĻŋāĻ-āĻāĻāĻŦāĻžāĻ° āĻĒā§āĻ°āĻā§āĻ°āĻŋāĻ¯āĻŧāĻžāĻāĻ°āĻŖ āĻāĻŽāĻ¨āĻāĻŋ āĻŦā§āĻ¯āĻ°ā§āĻĨāĻ¤āĻž āĻāĻāĻ˛ā§āĻ āĻ˛ā§āĻ¨āĻĻā§āĻ¨ āĻ˛āĻ āĻĒāĻĄāĻŧāĻž āĻāĻžāĻ˛āĻŋāĻ¯āĻŧā§ āĻ¯āĻžāĻ¯āĻŧāĨ¤ DataStream API-āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§, āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ°āĻāĻžāĻ°ā§āĻ°āĻž Debezium āĻāĻŦāĻ Kafka āĻ¨āĻŋāĻ¯āĻŧā§āĻāĻŋāĻ¤ āĻ¨āĻž āĻāĻ°ā§āĻ āĻāĻāĻžāĻ§āĻŋāĻ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻāĻŦāĻ āĻā§āĻŦāĻŋāĻ˛ā§āĻ° āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ āĻā§āĻŦāĻŋāĻ˛/āĻāĻ¸āĻāĻŋāĻāĻāĻ˛ āĻāĻĒāĻŋāĻāĻ-āĻāĻ° āĻāĻ¨ā§āĻ¯ āĻ¸āĻŋāĻĄāĻŋāĻ¸āĻŋ āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§, āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ°āĻāĻžāĻ°ā§āĻ°āĻž āĻāĻāĻāĻŋ āĻāĻāĻ āĻā§āĻŦāĻŋāĻ˛ā§ āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻ¨āĻŋāĻ°ā§āĻā§āĻˇāĻŖ āĻāĻ°āĻ¤ā§ āĻāĻāĻāĻŋ āĻ¸āĻŋāĻĄāĻŋāĻ¸āĻŋ āĻā§āĻ¸ āĻ¤ā§āĻ°āĻŋ āĻāĻ°āĻ¤ā§ āĻāĻ¸āĻāĻŋāĻāĻāĻ˛ āĻĄāĻŋāĻĄāĻŋāĻāĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ Apache FlinkÂŽ-āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§ āĻ¸ā§āĻ¨ā§āĻ¯āĻžāĻĒāĻļāĻ āĻĄā§āĻāĻž āĻā§āĻ°āĻšāĻŖ āĻāĻŦāĻ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻĨā§āĻā§ FlinkÂŽ-āĻ āĻ°āĻŋāĻ¯āĻŧā§āĻ˛ āĻāĻžāĻāĻŽ āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨ āĻ¸āĻŽāĻ°ā§āĻĨāĻ¨ āĻāĻ°ā§āĨ¤
āĻŦā§āĻļāĻŋāĻˇā§āĻā§āĻ¯
- āĻ āĻŋāĻ-āĻāĻāĻŦāĻžāĻ° āĻļāĻŦā§āĻĻāĻžāĻ°ā§āĻĨāĻŦāĻŋāĻĻā§āĻ¯āĻž
- āĻā§āĻŦāĻŋāĻ˛/āĻāĻ¸āĻāĻŋāĻāĻāĻ˛ API
- āĻĄā§āĻāĻžāĻ¸ā§āĻā§āĻ°āĻŋāĻŽ API
- āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ°āĻāĻžāĻ°ā§āĻ°āĻž āĻāĻāĻāĻŋ āĻāĻāĻ āĻā§āĻŦāĻŋāĻ˛ā§ āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻ¨āĻŋāĻ°ā§āĻā§āĻˇāĻŖ āĻāĻ°āĻ¤ā§ āĻāĻāĻāĻŋ āĻ¸āĻŋāĻĄāĻŋāĻ¸āĻŋ āĻāĻ¤ā§āĻ¸ āĻ¤ā§āĻ°āĻŋ āĻāĻ°āĻ¤ā§ SQL DDL āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§āĻ¨
- āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ°āĻāĻžāĻ°ā§āĻ°āĻž āĻāĻāĻ āĻāĻžāĻā§āĻ° āĻāĻāĻžāĻ§āĻŋāĻ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻāĻŦāĻ āĻā§āĻŦāĻŋāĻ˛ā§āĻ° āĻĒāĻ°āĻŋāĻŦāĻ°ā§āĻ¤āĻ¨āĻā§āĻ˛āĻŋ āĻā§āĻ°āĻžāĻ¸ āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§
- Apache FlinkÂŽ āĻāĻ° āĻāĻ¨ā§āĻ¯ CDC āĻ¸āĻāĻ¯ā§āĻāĻāĻžāĻ°ā§ āĻĄāĻžāĻāĻžāĻŦā§āĻ¸ āĻ¸ā§āĻ¨ā§āĻ¯āĻžāĻĒāĻļāĻ āĻĒāĻĄāĻŧāĻž āĻ¸āĻŽāĻ°ā§āĻĨāĻ¨ āĻāĻ°ā§ āĻāĻŦāĻ āĻŦāĻŋāĻ¨āĻ˛āĻ āĻĒāĻĄāĻŧāĻž āĻāĻžāĻ˛āĻŋāĻ¯āĻŧā§ āĻ¯āĻžāĻ¯āĻŧ
āĻĒā§āĻ°ā§āĻā§āĻ°āĻžāĻŽāĻŋāĻ āĻāĻžāĻˇāĻž
āĻāĻžāĻāĻž
āĻŦāĻŋāĻāĻžāĻ
āĻāĻāĻŋ āĻāĻāĻāĻŋ āĻ ā§āĻ¯āĻžāĻĒā§āĻ˛āĻŋāĻā§āĻļāĻ¨ āĻ¯āĻž https://sourceforge.net/projects/cdc-connec-apache-flink.mirror/ āĻĨā§āĻā§āĻ āĻāĻ¨āĻž āĻ¯ā§āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ āĻāĻŽāĻžāĻĻā§āĻ° āĻŦāĻŋāĻ¨āĻžāĻŽā§āĻ˛ā§āĻ¯ā§āĻ° āĻ āĻĒāĻžāĻ°ā§āĻāĻŋāĻ āĻ¸āĻŋāĻ¸ā§āĻā§āĻŽāĻā§āĻ˛āĻŋāĻ° āĻŽāĻ§ā§āĻ¯ā§ āĻāĻāĻāĻŋ āĻĨā§āĻā§ āĻ¸āĻŦāĻā§āĻ¯āĻŧā§ āĻ¸āĻšāĻ āĻāĻĒāĻžāĻ¯āĻŧā§ āĻ āĻ¨āĻ˛āĻžāĻāĻ¨ā§ āĻāĻžāĻ˛āĻžāĻ¨ā§āĻ° āĻāĻ¨ā§āĻ¯ āĻāĻāĻŋ OnWorks-āĻ āĻšā§āĻ¸ā§āĻ āĻāĻ°āĻž āĻšāĻ¯āĻŧā§āĻā§āĨ¤