备案控制台

开发者社区

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC中mysql有个blob字段，是压缩后在写入的，这种怎么解析到kafka？

Flink CDC中mysql有个blob字段，是压缩后在写入的，这种怎么解析到kafka？

展开

收起

cuicuicuic 2023-12-24 14:03:23 29 0

1 条回答

写回答

取消提交回答

xin在这

debezium.binary.handling.mode这个用base64可以转string，然后再from_base64，但是那种压缩的转不出来，只有那种不压缩的可以，此回答整理自钉群“Flink CDC 社区”

2023-12-25 08:02:59

赞同展开评论打赏

问答分类：

流计算关系型数据库 MySQL 消息中间件 Kafka 云消息队列 Kafka 版云解析DNS 云数据库 RDS MySQL 版实时计算 Flink版

问答标签：

云数据库 RDS MySQL 版字段云数据库 RDS MySQL 版flink 云数据库 RDS MySQL 版cdc 实时计算 Flink版cdc mysql cdc云数据库 RDS MySQL 版

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关产品：

实时计算 Flink版

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答

实时计算 Flink版

Flink为什么我kafka 写到mysql的数据字段对应关系变反了呢？

14

2

0

Flink CDC里通过datastream从mysql写到kafka中文乱码要配置什么的?

21

1

0

Flink CDC 里做全库同步的时候mysql到kafka、报这个错误是少什么东西了？

19

0

0

Flink因为源表的字段发生更改，请问对应的kafka topic，是否需要删掉重建呢？

17

1

0

flink cdc mysql写入kafka，update的时候产生俩条数据这个一般怎么处理？

20

0

0

Flink CDC里mysql做为CDC源，写入到kafka时报错，无法处理有更新和删除的数据咋办？

50

2

0

Flink CDC中flinksql采集mysql，这怎么解析到kafka，有方法解决吗？

24

0

0

Flink CDC有采集mysql压缩字段的吗？

22

0

0

各位大佬，请教一下，如果在flink cdc sql客户端使用SQL查询表，怎么能记录原系统的数据

1850

1

0

那cdc最新版支持到flink的哪个版本，flink1.15还有guava兼容性问题吗？

965

0

0

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

相关产品

实时计算 Flink版

文档详情产品详情

热门讨论

热门文章

FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？

flinkcdc3.0整库同步mysql的数据到starrocks中全量能过去增量过不去怎么排查？

Caused by: org.apache.kafka.common.errors.TimeoutE

flink1.15启动后无法访问webui的问题有人遇到过吗

Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行

Flink-CDC 文档网站地址是什么？

flink web UI 是不是本身不支持登录认证，必须通过nginx来加登录认证？

Flink CDC有遇见这个问题的吗？

Flink这个未授权访问漏洞有什么解决方案吗？

flink 1.18必须配套JDK11吗 1.8是不是不行了呢？

展开全部

数据仓库介绍与实时数仓案例

权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算

OPPO数据中台之基石：基于Flink SQL构建实数据仓库

分布式Snapshot和Flink Checkpointing简介

实时计算 Flink SQL 核心功能解密

Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化

流计算StreamCompute

Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示

流计算精品翻译: The Dataflow Model

接着！！Apache Flink 全领域干货合集（持续更新）

展开全部

相关课程

更多

Apache Flink 入门到实战 - Flink开源社区出品

1392

16

去学习

实时计算 Flink 版产品入门与实操

3806

10

去学习

开源 Flink 极速上手教程

1752

7

去学习

分布式消息系统 Kafka 快速入门

640

24

去学习

大数据实时计算框架Spark快速入门

778

93

去学习

Apache Flink 入门

4826

9

去学习

相关电子书

更多

Java Spring Boot开发实战系列课程【第16讲】：Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载

MaxCompute技术公开课第四季之如何将Kafka数据同步至MaxCompute 立即下载

消息队列kafka介绍 立即下载

相关实验场景

更多