问题一:flinkcdc sql连接oracle12c报这种问题是原因呢?stream api没有这种问题,讲道理跟kafka没有什么关系呗只要源端有数据变动就会报这种错误,flink1.16,flinkcdc2.3
大佬们,flinkcdc sql连接oracle12c报这种问题是原因呢?stream api没有这种问题,讲道理跟kafka没有什么关系呗只要源端有数据变动就会报这种错误,flink1.16,flinkcdc2.3
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/470492?spm=a2c6h.14164896.0.0.7cfbd9dfmRc7WX
问题二:请问用flink cdc同步mysql的数据到starrocks,源表与目标表的类型是和mysql一样吗?有类型映射关系表吗?
请问用flink cdc同步mysql的数据到starrocks,源表与目标表的类型是和mysql一样吗?有类型映射关系表吗?
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/439083?spm=a2c6h.14164896.0.0.5c71d9dfBYG7Od
问题三:使用flink cdc 2.1.1版本进行mysql到kafka的数据同步,正常同步了一个月时间,昨天数据库下线,flink cdc job没有抛出异常,看日志一直在不断重连数据库,重连了十几个小时,我们希望上游源数据库出现问题,flink cdc能够立即感觉,有什么办法吗?
请问一下各位大佬,使用flink cdc 2.1.1版本进行mysql到kafka的数据同步,正常同步了一个月时间,昨天数据库下线,flink cdc job没有抛出异常,看日志一直在不断重连数据库,重连了十几个小时,我们希望上游源数据库出现问题,flink cdc能够立即感觉,有什么办法吗?
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/439202?spm=a2c6h.14164896.0.0.5c71d9dfBYG7Od
问题四:Flink CDC 的上游支持了哪些数据源?
Flink CDC 的上游支持了哪些数据源?
参考回答:
Flink CDC 的上游已经支持了 MySQL、MariaDB、PG、Oracle、MongoDB 等丰富的数据源, 对 Oceanbase、TiDB、SQLServer 等数据库的支持也已经在社区的规划中。
资料来源:《Flink CDC:新一代数据集成框架》,下载链接:https://developer.aliyun.com/topic/download?id=8256。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/391312?spm=a2c6h.14164896.0.0.5c71d9dfBYG7Od
问题五:Flink CDC 的下游支持了哪些数据源?
Flink CDC 的下游支持了哪些数据源?
参考回答:
Flink CDC 的下游则更加丰富,支持写入 Kafka、Pulsar 消息队列,也支持写入 Hudi、Iceberg 等数据湖,还支持写入各种数据仓库。
资料来源:《Flink CDC:新一代数据集成框架》,下载链接:https://developer.aliyun.com/topic/download?id=8256。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/391313?spm=a2c6h.14164896.0.0.5c71d9dfBYG7Od