问题一:Flink CDC哪位能发下新版本postgresql flinkcdc连接器?
Flink CDC哪位能发下新版本postgresql flinkcdc连接器?
参考回答:
Apache Flink 有两个 PostgresCDC Connector:
- FlinkCDC-Kafka-SQL:一个 Flink SQL 插件,用于从 Postgres 数据库拉取数据并将其发送到 Kafka。
- FlinkCDC-Connector:一个外部连接器,可以与其他系统集成。
这两个项目均未与 Flink 社区整合。要获取最新的 PostgreSQL CDC 连接器,请参阅以下链接: - FlinkCDC-Kafka-SQL:https://nightlies.apache.org/flink/flink-cdc-connectors/master/docs/connectors/cdc/postgresql/
- FlinkCDC-Connector:https://nightlies.apache.org/flink/flink-cdc-connectors/master/docs/connectors/postgresql/
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572285
问题二:flink 啥时候能支持tidb连接器,有这个计划吗?
flink 啥时候能支持tidb连接器,有这个计划吗?
参考回答:
暂时没有计划,社区有连接器你可以自定义connector先用。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572580
问题三:Flink CDC1.13.2和flinkcdc2.0,读取mysql的cdc,有人遇到这个问题吗?
Flink CDC1.13.2和flinkcdc2.0,读取mysql的cdc,有人遇到这个问题吗?
https://github.com/ververica/flink-cdc-connectors/discussions/719
参考回答:
看着像是你自己自定义序列化的问题,先测试.deserializer(new JsonDebeziumDeserializationSchema())
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572283
问题四:使用cdc同步oracle 12c cdc数据库,根据文档要求创建账号 公用用户名或角色名无效?
使用cdc同步oracle 12c cdc数据库,根据文档要求创建账号 提示ORA-65096: 公用用户名或角色名无效?
参考回答:
sysdba
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572282
问题五:finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀?
finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀?
参考回答:
string和date都可以,映射表string,ES date(不加format),此时写入映射表的时候要手动加'T''Z'
映射表date,ES date就得在mapping设置format参数了,然后还可以映射表timestamp(0/3/6),ES keyword,三种方式 ES显示的格式是有差别的
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572281