SQL Server 数据订阅

最近更新时间:2025-03-17 14:34:23

我的收藏
注意:
SQL Server 数据订阅任务已停止新增,即将下线,存量任务限制修改和变更。欢迎使用其他正在开放的任务类型。

操作场景

CKafka 连接器支持接入各种数据源产生的不同类型的数据,统一管理,再分发给下游的离线/在线处理平台,构建清晰的数据通道。
CKafka 连接器支持订阅 SQL Server 变更数据,本文介绍在 CKafka 控制台创建 SQL Server 数据接入任务的操作方法。

前提条件

已创建好数据目标 Topic。
已创建好数据源 SQL Server 连接。
说明:
仅支持 SQL Server 2016 及以上的版本。

操作步骤

1. 登录 CKafka 控制台
2. 在左侧导航栏选择连接器 > 任务列表,选择好地域后,单击新建任务
3. 填写任务名称,任务类型选择数据接入,数据目标类型选择SQL Server数据订阅,单击下一步
4. 填写数据源配置信息,单击下一步。


数据源:选择提前创建好的 SQL Server 连接。
database:选择要监听的数据库。
table:选择要监听的数据表。
复制存量数据:是否复制源 SQL Server 的存量数据。
5. 选择数据目标 Topic。
自动创建 Topic:可以选择 CKafka 实例内 Topic 或者弹性 Topic,若选择 CKafka 实例内 Topic,则需要指定目标 CKafka 实例。支持批量连续命名或指定模式串命名,参考文档
选择已有 Topic:支持选择 弹性 Topic 或者 CKafka 实例内 Topic。选择 CKafka 实例内 Topic 时,若实例设置了 ACL 策略,请确保选中的 Topic 有读写权限。

6. 选择是否开启数据压缩,数据压缩可以减少网络 IO 传输量,减少磁盘存储空间,数据压缩说明
7. 单击提交,可以在任务列表看到刚刚创建的任务,在状态栏可以看到创建进度。