文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理

问题一:flink cdc 3.0对切片key是字符串不能进行切分吗? flink cdc 3.0对切片key是字符串不能进行切分吗? 参考答案: source是复用原来的,你这个错误不是切分key...

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理
文章 2024-03-18 来自:开发者社区

启动多个jar包来监听同一个数据库的binlog

如果你需要启动多个jar包来监听同一个数据库的binlog,并做不同的业务处理,你可以按照以下步骤进行配置: 在每个jar包中添加Flink CDC Connector依赖。例如,在pom.xml文件中添加如下依赖: <dependency> <groupId>org.apache.flink&...

问答 2024-01-01 来自:开发者社区

Flink CDC如果 1个数据库。我启动多个jar包 监听binlog 做不同的业务。怎么配置?

Flink CDC如果 1个数据库。我启动多个jar包 监听binlog 做不同的业务。怎么配置?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。