首页 > TAG信息列表 > ververica

FlinkCDC读取MySQL并写入Kafka案例(com.ververica)

该方法使用的是com.ververica版本的flink-connector-mysql-cdc，可以解决alibaba版本的以下两个问题： 1）可以有效避免锁表 2）当设置StartupOptions.latest()时做checkpoints可能出现的异常错误 因此不推荐使用alibaba的版本。   需要注意点，依赖的POM文件如下，标记为粗体的部分是需要注

JAVA整合FlinkCDC

  官方地址：https://github.com/ververica/flink-cdc-connectors   版本至少jdk8   maven <dependency> <groupId>com.ververica</groupId> <!-- add the dependency matching your database --> <artifactId>flink-connector-mysql-cdc</art

使用Flink cdc connector时，如果将一个change-log的数据源中使用TIMESTAMP类型时报错

已付费购买专栏的朋友，请在申请查看权限时，备注你的CSDN名称才能通过查看权限，如果未购买，请先购买专栏，再申请查看权限。谢谢配合，谢谢理解。 报错如下： 11665 [debezium-engine] ERROR com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction - Reporting error: java.lang.Ille

Flink on K8s部署

1.安装K8S 参考上篇博客K8S原理、安装和部署 2.安装Helm并加入环境变量 Helm可以帮忙管理k8s的应用,用它来安装minio和vvp，如果下载很慢，可以根据官网选择其他安装方式 wget https://get.helm.sh/helm-v3.5.4-linux-amd64.tar.gz tar -xvzf helm-v3.5.4-linux-amd64.tar.gz mv lin