AI 助理
备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

Flink CDC 里 这个pr 支持首次全量写入kafka？

Flink CDC 里 这个pr 支持首次全量写入kafka？ 直接jdbc 从数据库拉取数据，也是输出 debeium-json and canal-json ？73ae6c0a166cb81725599b36239d26d6.png

展开
收起
小小鹿鹿鹿 2024-03-19 23:07:08 44 发布于山西 分享
分享
 版权
举报

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

1 条回答
写回答
取消 提交回答
  • 小小杳杳杳

    支持。但是只输出数据的json。此回答来自钉群Flink CDC 社区。

    2024-03-20 11:07:16 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
问答分类：
流计算 消息中间件 Kafka Java 数据库连接 数据库 云消息队列 Kafka 版 实时计算 Flink版
问答标签：
实时计算 Flink版CDC 实时计算 Flink版kafka 实时计算 Flink版cdc kafka 实时计算 Flink版全量 云消息队列 Kafka 版flink
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
Flink CDC使用datax或者其他全量工具同步到kafka； 是这个意思吧？
274
2
0
Flink CDC全量是要读取完，kafka事务时间要大于全量读取完时间？
50
1
0
如果用flinkcdc将postgres数据同步到kafka。首次全量同步的时候怎么办程序挂掉重启？
136
1
0
用flinkcdc-oracle2.2.1全量同步数据到kafka，开始很快，然后掉一大截？
392
7
0
为啥我这源端kafka中没有新数据了，增量式ck存的数据还是2个g，跟全量式差不多？
256
1
0
mysqlcdc读取全量600万数据到kafka，flink tm的4g的内存不够用，有啥办法不？
242
0
0
mysqlcdc使用的时候，如果表名是中文，增量记录不能同步到kafka，全量是可以。为什么？
202
1
0
各位大佬，请教一下，如果在flink cdc sql客户端 使用SQL查询表，怎么能记录原系统的数据
1997
1
0
那cdc最新版支持到flink的哪个版本，flink1.15还有guava兼容性问题吗？
1139
0
0
flink cdc(mysql) -> elasticsearch7, 任务每次持续跑了一段时间之后
1147
2
0
大数据与机器学习

实时计算 Flink

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

我要提问

相关文章

  • 《通义灵码2.0 AI 程序员体验官招募》 获奖名单公布
  • 通过Milvus和Langchain快速构建基于百炼大模型的LLM问答系统
  • JetBrains IntelliJ IDEA 2025.1 发布 - 领先的 Java 和 Kotlin IDE
  • JetBrains DataGrip 2025.1 发布 - 数据库和 SQL 跨平台 IDE
  • Arthas monitor（方法执行监控）

    • 热门讨论

    热门文章

  • 如何用实时数据同步打破企业数据孤岛？
  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • Flink 集群重启后，所有的Jobs任务全都没有了。如果快速恢复所有的任务
  • 不同版本的 flink 如何适配不同版本 kafka，flink-connect-kafka 版本
  • flink中taskmanager产生的checkpoint文件占用空间一直增长是什么原因？
  • Flink CDC有没有办法忽略这些无主键的表，或者忽略这个错误呀？
  • 各位老师，请教个问题，flink 会在本地 /tmp 目录下产生大量flink-临时文件，目前看好？
  • flink cdc 有没得官方介绍文档？
  • flink 1.18必须配套JDK11吗 1.8是不是不行了呢？
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
    • 展开全部
  • Apache Flink 漫谈系列(04) - State
  • Apache Flink 零基础入门（五）：流处理核心组件 Time&Window 深度解析
  • 来！PyFlink 作业的多种部署模式
  • Apache Flink 进阶（三）：Checkpoint 原理解析与应用实践
  • Flink China 社区运营成果报告（7月-9月）
  • 基于 Flink 的超大规模在线实时反欺诈系统的建设与实践
  • 周末直播|Flink、Hologres、AI等热门话题全都安排！
  • 实时计算 Flink版操作报错之遇到错误org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'jdbc'，该如何解决
  • Flink 基础详解：大数据处理的强大引擎
  • Apache Paimon统一大数据湖存储底座
    • 展开全部
    还有其他疑问?
    咨询AI助理