tencent cloud

消息队列 CKafka 版

动态与公告
新功能发布记录
Broker 版本升级记录
公告
产品简介
TDMQ 产品系列介绍与选型
什么是消息队列 CKafka 版
产品优势
应用场景
技术架构
产品系列介绍
开源 Kafka 版本支持说明
与开源 Kafka 对比
高可用
使用限制
地域和可用区
相关云服务
产品计费
计费概述
价格说明
计费示例
按小时付费转包年包月
续费说明
查看消费明细
欠费说明
退费说明
快速入门
入门流程指引
准备工作
VPC 网络接入
公网域名接入
用户指南
使用流程指引
配置账号权限
创建实例
配置 Topic
连接实例
管理消息
管理消费组
管理实例
变更实例规格
配置限流
配置弹性伸缩策略
配置高级特性
查看监控和配置告警
使用连接器同步数据
实践教程
集群资源评估
客户端实践教程
日志接入
开源生态对接
替换支撑路由（旧）
迁移指南
迁移方案概述
使用开源工具迁移集群
故障处理
Topic 相关
客户端相关
消息相关
API 参考
History
Introduction
API Category
Making API Requests
Other APIs
ACL APIs
Instance APIs
Routing APIs
DataHub APIs
Topic APIs
Data Types
Error Codes
SDK 参考
SDK 概述
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
连接器相关 SDK
安全与合规
权限管理
网络安全
删除保护
事件记录
云 API 审计
常见问题
实例相关
Topic 相关
Consumer Group 相关
客户端相关
网络问题
监控相关
消息相关
服务协议
服务等级协议
联系我们
词汇表
文档消息队列 CKafka 版用户指南使用连接器同步数据连接器简介

连接器简介

PDF
聚焦模式
字号
最后更新时间： 2026-01-20 15:56:36

什么是连接器

CKafka 连接器是腾讯云上一款 SaaS 化的数据接入和处理工具，能够一站式实现数据的高效接入、处理及分发。主要提供 Kafka to Kafka 和 Kafka to Elasticsearch Service 两款数据流转插件，并内置简单可配置的数据清洗（ETL）能力，帮助用户低成本构建稳定可靠的数据流转链路。

Kafka to Kafka 插件介绍

应用场景

数据已经存在缓存层的消息队列 Kafka 中，需要进行清洗格式化 ETL 处理后，存储到下游 Kafka。
跨集群数据复制（腾讯云 CKafka 集群 → 腾讯云 CKafka 集群）：生产环境与灾备集群的实时热备，分散业务数据的统一汇聚。
跨云灾备（自建 Kafka 集群/其他云厂商 Kafka 集群 → 腾讯云 CKafka 集群）：IDC 环境与云上环境的灾备，双云或多云灾备场景。

功能说明

基于 Kafka 原生协议提供高吞吐、毫秒级延迟的传输能力，支持数据流无缝同步，同时支持智能路由规则（按 Topic、字段内容过滤）。通过断点续传和自动重试机制保障数据一致性，可兼容自建或跨云 Kafka 集群。

业务举例

电商订单数据实时分发给不同业务部门（如风控、物流、数据分析）分析。
金融行业核心业务的搭建多活架构。

Kafka to Elasticsearch Service 插件介绍

应用场景

CKafka 连接器支持将流式数据转化为可搜索、可分析的结构化存储，适用于实时日志监控、用户行为检索或 IoT 设备状态分析等多种场景。例如：
业务日志通过 Kafka 同步至 Elasticsearch Service 后，并借助 Kibana 实现运维监控可视化。
实时写入用户点击流或订单数据至 Elasticsearch Service，支持复杂条件的快速检索与查询。

功能说明

连接器提供近实时写入（数据秒级可见）、自动索引管理（动态适配 JSON 结构）及数据预处理能力（JSON 解析、字段裁剪），并通过死信队列机制有效隔离异常数据，结合重试策略保障传输可靠性。

业务举例

在线教育平台中的用户学习行为分析。
智能硬件场景下传感器异常数据的快速定位与排查。

CKafka 连接器插件生命周期说明

消息队列 CKafka 连接器目前商业化提供的插件为 Kafka to Kafka 和 Kafka to Elasticsearch Service。
商业化规划内的插件：
插件类型
插件名称
生命周期阶段
EOM 时间
EOS 时间
数据流出
商业化（GA）
暂无计划
暂无计划
商业化（GA）
暂无计划
暂无计划
数据接入
公测
暂无计划
暂无计划
公测后计划下线的插件：
插件类型
插件名称
生命周期阶段
EOM 时间
EOS 时间
数据流出
CTSDB
停止新购（EOM）
2024年10月31日
预计 2025年10月31日
TDSQL-C PostgreSQL
停止新购（EOM）
2024年10月31日
预计 2025年10月31日
数据仓库 ClickHouse
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
分析型数据库 Doris
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
数据库 MySQL
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
PostgreSQL
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
云数据仓库 PostgreSQL
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
TDSQL PostgreSQL版
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
分布式数据仓库 TDW
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
对象存储 COS
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
日志服务 CLS
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
云函数 SCF
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
事件总线 EventBridge
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
数据接入
MariaDB 数据订阅
停止新购（EOM）
2024年10月31日
预计 2025年10月31日
TDSQL-C PostgreSQL 数据订阅
停止新购（EOM）
2024年10月31日
预计 2025年10月31日
MongoDB 数据订阅
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
MySQL 数据订阅
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
MySQL 数据接入
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
PostgreSQL 数据订阅
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
SQL Server 数据订阅
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
TDSQL-C MySQL数据订阅
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
数据上报 HTTP
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
数据传输服务 DTS
停止新购（EOM）
2024年10月31日
预计 2026年6月30日
说明：
EOM：End of Marketing，停止该版本的销售。
EOS：End of Service & Support，停止该版本的服务，在该日期之后，不再提供该软件版本的任何技术服务支持。
上一篇: 开启一键诊断下一篇: 配置 Kafka 之间的数据同步

帮助和支持

本页内容是否解决了您的问题？

填写满意度调查问卷，共创更好文档体验。

文档反馈