问答 2024-08-18 来自:开发者社区

flink cdc datastream方式同步mysql数据到kafka,多分区怎么保证有序性?

flink cdc datastream方式同步mysql数据到kafka,多分区怎么保证有序性?

问答 2024-08-14 来自:开发者社区

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?只同步一张表就没有问题 org.apache.flink.table.api.ValidationException: SQL validation failed. From line 195, column 6 to line 195, column 19: Unknown target column 'value__...

问答 2024-08-07 来自:开发者社区

Flink想再从mysql同步到kafka的 要怎么操作的?

mysql分表的数据库表 ctas的方式同步到starrocks会多出两个列 Flink想再从mysql同步到kafka的 要怎么操作的?

问答 2024-08-07 来自:开发者社区

使用flinkcdc 3.1.1 同步mysql到kafka,改表结构之后就不能从 特定位置起了吗?

使用flinkcdc 3.1.1 同步mysql到kafka,改表结构之后就不能从 特定位置起了吗?只能从 initial 重新开始?

问答 2024-08-07 来自:开发者社区

阿里云实时计算flink,cdc同步数据到kafka,cdas、ctas都失败,大家有遇到吗?

阿里云实时计算flink,cdc同步数据到kafka,cdas、ctas都失败,Message: code: 400, The config: [cleanup.policy] not in enums. format is invalid,大家有遇到吗?

问答 2024-07-31 来自:开发者社区

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段?

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到op before after字段?

问答 2024-07-31 来自:开发者社区

如果用flinksql的方式同步mysql数据到kafka,是类似DTS那样吗?

如果用flinksql的方式同步mysql数据到kafka,是类似DTS那样只要数据变更有binlog就会往kafka投递消息么?

问答 2024-07-31 来自:开发者社区

在Flink CDC中,用pipeline 连接器 同步mysql数据到kafka报错了,缺少什么?

在Flink CDC中,用 pipeline 连接器 同步mysql数据到kafka报错了,是缺少什么依赖了吗?

文章 2024-07-17 来自:开发者社区

DataWorks产品使用合集之如何离线增量同步Kafka数据,并指定时间范围进行同步

问题一:dataworks为什么在Datastudio中看不到odps sql的新建节点菜单? dataworks为什么在Datastudio中看不到odps sql的新建节点菜单? 参考回答: https://help.aliyun.com/zh/dataworks/user-guide/create-a-maxcompute-data-source...

DataWorks产品使用合集之如何离线增量同步Kafka数据,并指定时间范围进行同步
问答 2024-07-17 来自:开发者社区

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?mysql -> flink cdc -> kafka -> flink -> sr 这个样子的

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

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等