阿里云文档 2024-09-30

如何将PolarDB-X1.0同步至阿里云消息队列Kafka

本文介绍如何使用数据传输服务DTS(Data Transmission Service)将PolarDB-X 1.0同步至阿里云消息队列Kafka。

阿里云文档 2023-09-06

如何将RDSMySQL同步至阿里云消息队列Kafka版

数据传输服务DTS(Data Transmission Service)支持RDS MySQL实例同步至阿里云消息队列Kafka版。

问答 2023-08-20 来自:开发者社区

DataWorks同步kafka数据时,指定时间 这个配置对应的是 kafka数据中的 字段对么?

DataWorks同步kafka数据时,指定时间 这个配置对应的是 kafka数据中的 timestamp 字段对吗? 这个 timestamp 是数据写入kafka的时间吗?

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

hello,请教下,我有个flinkcdc任务,同步mysql中的一张表到kafka,表量级不大?

$stringUtil.substring( $!{XssContent1.description},200)...

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

Flink CDC中dinky整库同步到kafka,datetime类型变成毫秒数,怎么解决?

问题1:Flink CDC中dinky整库同步到kafka,datetime类型变成毫秒数,怎么解决?问题2:datastream api 自定义时间转换器就可以转,sql方式应该没有方式可以转吧?

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

Flink中cdas整库同步是否支持sink段到kafka形成一个topic?目前我知道是不可以的,

Flink中cdas整库同步是否支持sink段到kafka形成一个topic?目前我知道是不可以的,不知道未来会不会这样做,那就只能用datastream接入全部数据打入kafka单topic了,加解密数据,愁死人了,加解密还不让我们来操作 看来得看看paimon

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

问一下各位大佬,在使用flinkcdc 同步 oceanbase(企业版本)数据到kafka时,?

问一下各位大佬,在使用flinkcdc 同步 oceanbase(企业版本)数据到kafka时,logproxy.host 参数怎么获取?

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

你好,我用dataworks同步我们自己阿里服务器的kafka, 会报错不能识别主机名,请问?

你好,我用dataworks同步我们自己阿里服务器的kafka, 会报错不能识别主机名,请问hosts映射在哪配置的?

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

有没有大佬 搞过 Flink CDC 整库同步 oracle 到 kafka , 合并的那种 ?

有没有大佬 搞过 Flink CDC 整库同步 oracle 到 kafka , 合并source 的那种 ?

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

通过canal同步数据,消费kafka数据时出现了别的数据库里的信息

$stringUtil.substring( $!{XssContent1.description},200)...

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注