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

Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的?

Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的能力吗

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

各位,flink mysql-cdc ,使用序列化数据,数字主键id 变成其它东西了,又遇见过这情?

问题1:各位,flink mysql-cdc ,使用JsonDebeziumDeserializationSchema() 序列化数据,数字主键id 变成其它东西了,又遇见过这情况么?入下图 版本 2.2.0 问题2:我用的是cdc 自带的,不是自己写的 整型

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

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我?

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我使用的是sql-client提交的sql,我在官方文档没找到怎么设置?

问答 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中存在非序列化属性

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

实时计算 Flink版avro 序列化失败是什么原因?

实时计算 Flink版avro 序列化失败是什么原因?

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

flink cdc 同步的序列化默认转成什么对象?

flink cdc 同步的序列化JsonDebeziumDeserializationSchemajson,默认转成什么对象?

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

flink cdc 默认的序列化对象是什么?

flink cdc 默认的序列化对象是什么?

文章 2022-12-30 来自:开发者社区

阿里一面:Flink的类型与序列化怎么做的

一、DataStream类型系统1.1 物理类型1.2 逻辑类型1.3 类型推断1、类型提取的时机#DataStream.java在使用DataStream#map接口的时候,就会触发类型的提取。 2、自动类型推断        Flink首先会自动进行类型推断,但是对于一些带有泛型的类型,Java泛型的类型擦除机制会导致Flink在处理Lambda表达式....

阿里一面:Flink的类型与序列化怎么做的
问答 2022-12-04 来自:开发者社区

Flink CDC flink 1.13+ cdc2.1.1 抽取 oracle ,报序列化问题,有

Flink CDC flink 1.13+ cdc2.1.1 抽取 oracle ,报序列化问题,有遇到吗?

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