问题一:flinkcdc 排除掉一些表,这个表不采集,哪位设置过啊?
flinkcdc 排除掉一些表,这个表不采集,哪位大佬设置过啊?我没写这表,但是它一直保错这张表,请dba查了一下,说要抽的表没有和这表没有关联关系,表名有大小写呢,这个会影响?
参考答案:
表实在太多的话就fifter,表不多的话直接把表名都写出来不就行了,mysql有个忽略大小写的设置,这个表因为大小写字母都有,存在问题,再往后我就不清楚了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580713
问题二:Flink CDC有人知道这个format怎么写?
Flink CDC有人知道这个format怎么写,能让时间格式变成2023-06-08T08:08:08+08:00这样么?
参考答案:
DATE_FORMAT(NOW(), '%Y-%m-%dT%H:%i:%s+08:00')
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580711
问题三:Flink CDC中hudi connector必须在hadoop环境下运行吗?
Flink CDC中hudi connector必须在hadoop环境下运行吗?
参考答案:
Flink CDC的hudi connector不一定需要在Hadoop环境下运行。但是,请注意,Hudi是一个流式数据湖平台,它能够连通Hadoop和Hive,支持对数据record粒度的各种操作。在一些案例中,它是采用Flink MySQL CDC Connector将RDBMS(MySQL)的Binlog数据实时写入数据湖的。所以,如果计划使用这样的配置,确保你的环境包含Hadoop是有必要的。同时,你需要保证使用的Flink版本和Hudi版本能够兼容,例如Flink 1.13.1与Hudi 0.10.1的整合使用在许多场景中都被广泛推荐。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580710
问题四:flink mysql cdc配置debezium的table.exclude.list不会生效吗?
flink mysql cdc配置debezium的table.exclude.list不会生效吗?
参考答案:
关于 Flink MySQL CDC 配置 Debezium 的 table.exclude.list 不生效的问题,可能是由于以下原因:
- 配置参数名称或格式错误:请确保你使用的参数名称和格式与 Debezium 文档中指定的完全一致。
- 配置覆盖或者冲突:检查你的 Flink CDC 配置文件,确保 table.exclude.list 参数没有被其他配置项覆盖或者冲突。
- 表名大小写敏感:在某些数据库系统中,表名是大小写敏感的。请确保你在 table.exclude.list 中使用的表名与实际表名的大小写匹配。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580708
问题五:Flink CDC怎么用Kibana查看啊?
Flink CDC怎么用Kibana查看啊?
参考答案:
可以百度一下 kibana有写dsl的入口
关于本问题的更多回答可点击进行查看: