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

Flink CDC中这里除了支持有支持canal json吗!大佬们 都用的什么版本啊?

Flink CDC中这里除了支持JsonDebeziumDeserializationSchema, 有支持canal json吗 大佬们 都用的什么版本啊?

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

Flink CDC 中canal-json和debizum-json,大家都是用哪个?

Flink CDC 中canal-json和debizum-json,大家都是用哪个?

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

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列?

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列化写法不对吗 JsonDeserializationSchema jsonFormat=new JsonDeserializationSchema<>(RuleDetail.class); KafkaSource source = KafkaSource.builder() ...

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

各位大佬,用flink cdc读取pg的json,json结构不一定,有办法用flinksql写入?

各位大佬,用flink cdc读取pg的json,json结构不一定,有办法用flinksql写入es吗?

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

请教个问题,Flink CDC 中tidb canal-json ts字段,有没有可能同一主键两条操

请教个问题,Flink CDC 中tidb canal-json ts字段,有没有可能同一主键两条操作不同日志ts值相同

问答 2023-04-26 来自:开发者社区

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者si

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者sink到Redis?

问答 2023-04-26 来自:开发者社区

flink cdc datastream api,数据格式 :json 发现binlog中的da

flink cdc datastream api,数据格式 :json 发现binlog中的datetime类型为long类型时间戳 这个怎么搞 大哥们? chatgpt给的 这个 好像没这个参数?

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

Flink CDC中用cdc怎么处理json字段啊?

Flink CDC中用cdc怎么处理json字段啊?

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

Flink CDC 设置多张表,sink端根据获取jSON数据里的table字段区分表吗?

DataStream API 里的 .tableList 如果设置多张表,sink端根据获取jSON数据里的table字段区分表吗?

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

flink cdc 同步的json应该转什么对象?

flink cdc 同步的json应该转什么对象?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注