问答 2023-12-20 来自:开发者社区

Flink CDC反序列化怎么写?

Flink CDC反序列化怎么写?

问答 2023-12-01 来自:开发者社区

Flink CDC对于这种DEFAULT VALUE 序列化不支持?

Flink CDC对于这种DEFAULT VALUE 序列化不支持?

问答 2023-09-13 来自:开发者社区

Flink CDC读binlog单线程 现在性能卡在反序列化上。有啥优化措施么?

Flink CDC读binlog单线程 现在性能卡在反序列化上。有啥优化措施么MySqlRecordEmitter debeziumDeserializationSchema.deserialize?

问答 2023-09-12 来自:开发者社区

Flink CDC中kafkasink时报序列化错误,有同学遇到吗?

Flink CDC中kafkasink时报序列化错误,有同学遇到吗,本地idea正常运行,提交到集群一直报这个错?

问答 2023-08-22 来自:开发者社区

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗?

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗,用的群文件的DataStreamJob

问答 2023-05-30 来自:开发者社区

周末好,大佬们。Flink CDC中有在线的大佬帮看看么,不能序列化?

周末好,大佬们。Flink CDC中有在线的大佬帮看看么 flinkcdc sqlserver 报错 Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: com.ververica.cdc.connectors.sqlserver.SqlServerValidator@1e965684 .....

问答 2023-05-01 来自:开发者社区

老师你好,请问flink cdc,支持将库的binlog序列化 Debezium格式化,写到kafk

老师你好,请问flink cdc,支持将库的binlog序列化 Debezium格式化,写到kafka么?这样子只需要同步一次数据库的binlog到kafka,下游可以根据需要,消费kafka获取自己需要table,这样子不会对业务mysql库产生压力?目的是想把整库发到kafka,这样子。在create table 的时候,schema就不是有个表了

问答 2023-05-01 来自:开发者社区

请问有人在用flink CDC 时遇到序列化的问题吗? springboot中我是想在customS

请问有人在用flink CDC 时遇到序列化的问题吗? springboot中我是想在customSink中注入ElasticsearchTemplate,将数据往es中存放,但是报错提示customSink中存在非序列化属性

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