问答 2022-08-04 来自:开发者社区

谁能解答?从mysql的binlog读取数据到kafka,但是数据类型有Insert,updata,

谁能解答?从mysql的binlog读取数据到kafka,但是数据类型有Insert,updata,delete ,如何保证通过flink流式计算kafka出来的结果跟在mysql计算出来的一样呢?就比如,mysql是select id,sum(money) money from tb1 group by id; 那么此时flink sql应该怎么写呢?

问答 2022-08-04 来自:开发者社区

flink-cdc支持并行读取一张mysql表的binlog不?

flink-cdc支持并行读取一张mysql表的binlog不?

问答 2022-08-04 来自:开发者社区

flink cdc怎么指定位点,从某个位点开始消费mysql的Binlog?

flink cdc怎么指定位点,从某个位点开始消费mysql的Binlog?

问答 2022-08-03 来自:开发者社区

cdc抽取mysql整个实例的binlog,有没有方案通过配置的方式将这些库表拆开分发到kafka

cdc抽取mysql整个实例的binlog,有没有方案通过配置的方式将这些库表拆开分发到kafka

问答 2022-07-28 来自:开发者社区

flinkcdc 消费 mysql binlog 没有 sqltype=delete 的数据是什么原

flinkcdc 消费 mysql binlog 没有 sqltype=delete 的数据是什么原因

问答 2022-07-27 来自:开发者社区

MySQL binlog的这种时间怎么处理呢??

MySQL binlog的这种时间怎么处理呢??

问答 2022-07-27 来自:开发者社区

有大佬用flink读取mysql binlog分表后再写入新表吗

有大佬用flink读取mysql binlog分表后再写入新表吗

问答 2022-07-27 来自:开发者社区

mysql cdc 如果binlog日志文件不全,全量阶段能读到所有数据吗

mysql cdc 如果binlog日志文件不全,全量阶段能读到所有数据吗

问答 2022-07-27 来自:开发者社区

大佬们,mysql版本低,不支持cdc,所以canal同步binlog至kafka,数据同步至cli

大佬们,mysql版本低,不支持cdc,所以canal同步binlog至kafka,数据同步至clickhouse,这个更新操作怎么做呀?更新部分字段

问答 2022-07-27 来自:开发者社区

大佬们,我用FLlincCDC监控mysql的binlog后,假如得到{id:1,name:马大帅}

大佬们,我用FLlincCDC监控mysql的binlog后,假如得到{id:1,name:马大帅},我需要去数据库查询关联表,使其变成{id:1,name:马大帅,height:188,age:18},然后把这个传给kafka。我可以通过FlinkCDC实现这个扩充表的操作吗

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

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问