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

FlinkCDC监听Mysql binlog,建立链接不会释放

如果有多个flink作业,每个都监听mysql内的binlog,每个都会与mysql建立链接并不会中断,过多占用mysql连接数影响其他进程与mysql的链接,有什么解决方法吗?

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

flinkcdc在监听binlog时如果程序停掉,中途又新增,如何让程序在停掉的点重新监听?

flinkcdc在监听binlog时如果程序停掉,中途又新增,如何让程序在停掉的点重新监听?

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

flinkcdc在监听binlog的时候如果程序停掉了,如何能让程序在停掉的那个点重新监听呢?

flinkcdc在监听binlog的时候如果程序停掉了,中途binlog又有新增,如何能让程序在停掉的那个点重新监听呢?

问答 2023-07-19 来自:开发者社区

请问flinkcdc中我现在的就是多库不可能做到一个job监听多个不同ip的实例binlog?

请问flinkcdc中我现在的就是多库,但是cdc又只能写一个ip,我那个分库,是分到不同的ip的数据库,不是在同一个实例的数据库,所以相当于有很多个binlog监听,这时候,是不是只能一个job监听一个数据库实例了,不可能做到一个job监听多个不同ip的实例binlog?

问答 2023-06-18 来自:开发者社区

flinkcdc 监听解析mysql的binlog文件,相关的binlog offset是直接往状?

flinkcdc 监听解析mysql的binlog文件,相关的binlog offset是直接往状态存储了,那如果任务失败或者异常了,相关的offset已经被提交了,那如何保证数据不丢失呢?有没有大佬对这一块有做过验证的,下游算子的恢复如果没有使用状态,依托于flink的算子生命周期是否也是可以保证数据的精准一次?有大佬可以解答一下吗?这个其实我已经知道了,我好奇的是,如果中间缓存数据我没有使用....

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

问个问题,我的Flinkcdc已经跑通了,可以监听msql的binlog了,也能发送kafk

问个问题,我的Flinkcdc已经跑通了,可以监听msql的binlog了,也能发送kafka消费了,但是我要怎样把这个东西部署呢。是需要在linux上搭一个Flink吗?

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