max_fetch_bytes 否 Integer 最大字节数 polling_interval 否 Integer 拉取周期 polling_unit 否 String 拉取周期单位 枚举值： ms s 响应参数 状态码： 200 表5 响应Body参数 参数 参数类型 描述 trigger_id

查看更多 →

将 GaussDB (for MySQL)同步到Kafka 支持的源和目标数据库 表1 支持的数据库 源数据库 目标数据库 GaussDB(for MySQL)主备实例 Kafka 使用建议 DRS任务启动和全量数据同步阶段，请不要在源数据库执行DDL操作，否则可能导致任务异常。 为

查看更多 →

以下链路由白名单转为公测支持标准。 MySQL->GaussDB分布式版 Oracle->GaussDB分布式版 GaussDB分布式版->Oracle GaussDB分布式版->GaussDB(DWS) GaussDB分布式版->Kafka GaussDB分布式版->GaussDB分布式版 公测 支持的数据库

查看更多 →

访问权限 。 MapReduce服务（ MRS Hudi） Hudi是一种 数据湖 的存储格式，在Hadoop文件系统之上提供了更新数据和删除数据的能力以及消费变化数据的能力。支持多种计算引擎，提供IUD接口，在HDFS的数据集上提供了插入更新和增量拉取的流原语。 Hudi的元数据存放在Hive中，操作通过Spark进行。

查看更多 →

fromJobConfig.topicsList 是 String Kafka topic列表，可以为多个topic，以“,”作为分隔符。 fromJobConfig.kafkaConsumerStrategy 是 枚举 从Kafka拉取数据时的初始偏移量设置： LATEST：最大偏移量，即最新的数据。

查看更多 →

MySQL数据库兼容MySQL模式 MySQL数据库兼容性概述 数据类型 系统函数 操作符 字符集 排序规则 SQL 驱动 父主题： 分布式

查看更多 →

当前实例与对端实例网络是否打通。 对端kafka地址是否有误。 认证方式：有密码选择SASL_SSL；无密码选择PLAINTEXT。 三种同步方式 拉取：把对端Kafka实例数据复制到当前Kafka实例中。 推送：把当前Kafka实例数据复制到对端Kafka实例中。 双向：两端Kafka实例数据进行双向复制。

查看更多 →

不支持 出云 MySQL->MySQL 支持 仅支持单AZ任务升级 出云 MySQL->kafka 支持 仅支持单AZ任务升级 出云 MySQL-> CSS /ES 支持 仅支持单AZ任务升级 出云 MySQL->Oracle 支持 仅支持单AZ任务升级 出云 MySQL->MariaDB

查看更多 →

Hmmss时，最终均以UUID格式为准。 服务集成 表2 APIC约束与限制 功能模块 约束与限制 DataAPI响应体大小 DataAPI返回数据Body不能大于10M。 DataAPI返回数据条数数量 DataAPI默认从数据库拉取的条数为2000条，如果条数超过2000条，超出部分将无法返回。

查看更多 →

fromJobConfig.topicsList 是 String Kafka topic列表，可以为多个topic，以“,”作为分隔符。 fromJobConfig.kafkaConsumerStrategy 是 枚举 从Kafka拉取数据时的初始偏移量设置： LATEST：最大偏移量，即最新的数据。

查看更多 →

操作”列的“暂停”。 在弹出的“暂停任务”对话框中，选择“暂停日志抓取”后，单击“是”。 暂停任务时，仅暂停增量数据的回放、或者拉取加回放，在进行数据库割接前，请先结束任务。 勾选“暂停日志抓取”后，该功能会停止一切DRS和源库、目标库的连接，请注意暂停过长可能会因为源端所需日志

查看更多 →

连接地址： 搭建kafka的broker地址列表，以逗号分隔。 主题： 用户自建的topic。 批处理大小：单次函数拉取最大数据量。 单击“确定”，完成开源kafka触发器的创建。 函数网络配置需要和创建kafka的ecs节点网络配置一样，包括vpc和子网。 激活kafka触发器 开源

查看更多 →

Consumer数量不能超过Topic分区数，否则会有Consumer拉取不到消息。 Consumer需周期poll，维持和server的心跳，避免心跳超时，导致Consumer频繁加入和退出，阻塞消费。 Consumer拉取的消息本地缓存应有大小限制，避免OOM（Out of Memory）。

查看更多 →

已登录数据复制服务控制台。 迁移任务正常运行中。 暂停任务 在“实时迁移管理”页面的迁移列表中，选择要暂停的迁移任务，单击“操作 > 暂停”。 在弹出的“暂停任务”对话框中，选择“暂停日志抓取”后，单击“是”。 增量状态暂停任务时，仅暂停增量数据的回放、或者拉取加回放，在进行数据库割接前，请先结束任务。

查看更多 →

connect.keep.alive，一旦发生拉取Binlog线程与MySQL服务器的连接连接异常，拉取Binlog线程不会尝试自动重连，这可能导致无法正常从源端拉取binlog日志。 语法格式 create table mySqlCdcSource ( attr_name attr_type

查看更多 →

pay_time >= concat(substr("2021-03-25 12:03:00", 1, 10), " 00:00:00") --取今天数据，为了方便运行，这里使用"2021-03-25 12:03:00"替代cast(LOCALTIMESTAMP as string)

查看更多 →

connect.keep.alive，一旦发生拉取Binlog线程与MySQL服务器的连接连接异常，拉取Binlog线程不会尝试自动重连，这可能导致无法正常从源端拉取binlog日志。 语法格式 create table mySqlCdcSource ( attr_name attr_type

查看更多 →

服务部署、启动、升级和修改时，拉取镜像失败如何处理？ 原因分析 节点磁盘不足，镜像大小过大。 解决方法 首先考虑优化镜像，减小节点磁盘的占用。 优化镜像无法解决问题，请联系系统管理员处理。 父主题： 服务部署

查看更多 →

创建MySQL数据库 应用场景 MySQL是目前最受欢迎的开源数据库之一，其性能卓越，搭配LAMP（Linux + Apache + MySQL + Perl/PHP/Python），成为WEB开发的高效解决方案。 本教程将指导您如何通过Terraform脚本创建一个RDS for

查看更多 →

数据库代理（MySQL） 开启数据库代理 查询数据库代理信息列表 查询数据库代理规格信息 设置读写分离路由模式 关闭数据库代理 父主题： API v3（推荐）

查看更多 →

producer_partition_by 否 分区策略，用来确保相同一类的数据写入到kafka同一分区 database：使用数据库名称做分区，保证同一个数据库的事件写入到kafka同一个分区中 table：使用表名称做分区，保证同一个表的事件写入到kafka同一个分区中 database ignore_producer_error

查看更多 →