腾讯云
最新活动
HOT
产品
解决方案
定价
企业中心
云市场
开发者
客户支持
合作与生态
了解腾讯云
关闭
搜索
消息队列 CKafka
动态与公告
新功能发布记录
连接器发布记录
Broker 版本升级记录
产品简介
产品概述
产品优势
应用场景
技术原理
开源对比
使用限制
地域和可用区
购买指南
产品规格
计费概述
包年包月
按量计费
购买方式
欠费说明
退费说明
快速入门
入门流程指引
获取访问授权
VPC 网络接入
步骤1:创建实例
步骤2:创建 Topic
步骤3:添加 VPC 网络路由
步骤4:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
公网域名接入
步骤1:创建实例
步骤2:添加公网路由
步骤3:创建 Topic
步骤4:配置 ACL 策略
步骤5:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
操作指南
实例管理
创建实例
批量连续命名或指定模式串命名
查看实例
升配实例
销毁/退还实例
升级实例版本
添加路由策略
公网带宽管理
接入外部监控 Prometheus
迁移可用区
设置系统维护时间
配置消息大小
Topic 管理
实例 Topic
创建 Topic
查看 Topic
删除 Topic
发送消息
设置 Topic 限流规则
弹性 Topic
Topic 管理
订阅管理
Consumer Group
概述
创建 Consumer Group
查询 Consumer Group
删除 Consumer Group
设置 Offset
自动重置 offset
连接器
连接器简介
连接器概述
连接器优势
应用场景
技术原理
使用限制
连接管理
任务管理
新建数据接入任务
HTTP 上报
对象存储 COS
数据传输服务 DTS
MariaDB 数据订阅
MongoDB 数据订阅
MySQL 数据订阅
MySQL 数据接入
PostgreSQL 数据订阅
SQL Server 数据订阅
TDSQL-C MySQL 数据订阅
TDSQL-C PostgreSQL 数据订阅
新建数据流出任务
数据目标
消息队列 CKafka
数据仓库(ClickHouse)
时序数据库(CTSDB)
日志服务(CLS)
对象存储(COS)
分析型数据库 Doris
Elasticsearch Service
事件总线(Event Bridge)
数据库 MySQL
PostgreSQL
云数据仓库-PostgreSQL
TDSQL-C PostgreSQL
TDSQL PostgreSQL 版
分布式数据仓库(TDW)
简单数据处理
数据解析
解析内部 JSON 结构
日期格式处理
字段修改
数据转换
正则表达式自动生成
过滤器规则说明
任务编排
Schema 管理
管理任务
查看监控
查看消息
事件中心
监控告警
查看监控信息
查询高级监控(专业版)
配置告警
告警配置建议
查看高级运维特性(专业版)
智能运维
一键诊断
弹性伸缩
磁盘水位处理
分区动态处理
权限管理
配置 ACL 策略
访问管理 CAM
标签管理
标签概述
使用标签
编辑标签
查询消息
事件中心
迁移上云
迁移方案概述
步骤1:购买云上实例
步骤2:迁移 Topic 上云
步骤3:迁移数据上云
方案1:单写双消费迁移
方案2:单写单消费迁移
方案3:使用 Mirrormaker 迁移
方案4:迁移未消费数据
集群备份
数据压缩
最佳实践
连接器最佳实践
HTTP 上报
HTTP 协议接入 Kafka
统一数据上报
数据库变更订阅查询
Mongo Stream 数据变更记录分析
MySQL 数据变更记录分析
PostgreSQL 数据变更记录分析
MySQL 到 Elasticsearch 实时数据同步
PostgreSQL 到 Elasticsearch 实时数据同步
替换 Canal 实现 MySQL 数据库订阅
数据简单清洗
日志采集处理查询
TKE 日志
Flink 接入 CKafka
Schema Registry 接入 CKafka
Spark Streaming 接入 CKafka
Flume 接入 CKafka
Kafka Connect 接入 CKafka
Storm 接入 CKafka
Logstash 接入 CKafka
Filebeat 接入 CKafka
跨可用区部署
生产消费最佳实践
日志接入
日志服务 CLS
容器服务(TKE) 日志
云防火墙日志
安全运营中心
日志检索
WAF 日志投递
替换支撑路由(旧)
故障处理
Topic 相关故障
Topic 创建失败
Topic 无监控数据
Topic 配置 ACL 策略后导致其他产品联动能力失效
分区的监控查看消息堆积数量一直存在
Consumer Group 相关故障
Consumer Group 列表详情缺失
Consumer Group 持续出现 PreparingRebalance 状态
客户端相关故障
客户端常见报错与解决方案
客户端生产消息进入到阻塞状态
客户端消费不到消息
Sarama 客户端异常
消息相关故障
消费数据异常
过期消息没有被及时删除
消费速度缓慢
出现消息堆积的警告
生产一段时间后发现持续性错误
API 文档
更新历史
简介
API 概览
调用方式
请求结构
公共参数
签名方法 v3
签名方法
返回结果
参数类型
实例相关接口
设置实例属性
设置Groups 消费分组offset
获取实例列表详情
获取实例列表信息
获取实例属性
获取消费分组offset
获取消费分组信息
创建实例(预付费包年包月)
删除预付费实例
删除消费组
预付费实例变配接口
获取Datahub消费分组offset
Ckafka询价
创建按量计费实例
主题相关接口
设置主题属性
获取主题列表详情
获取主题属性
获取主题列表
删除主题IP白名单
删除主题
创建主题IP白名单
创建主题
增加主题分区
根据位点查询消息列表
查询消息
查询订阅某主题消息分组信息
批量设置主题属性
批量修改消费组offset
创建消费者组
查询cdc任务接口
查询Datahub Topic最新消息列表
查询Datahub Topic消息
删除Datahub主题
查询topic生产端连接信息
获取Topic 同步副本信息
ACL相关接口
修改密码
查询用户信息
枚举ACL
删除用户
删除ACL
添加用户
添加 ACL 策略
删除ACL规则
批量添加 ACL 策略
路由相关接口
查看路由信息
添加实例路由
删除路由
Datahub 相关接口
HTTP发送消息
其他接口
枚举消费分组(精简版)
查询消费分组信息
查询用户列表
枚举地域
查看可用区列表
修改路由触发时间
创建token
取消授权token
实例授权token
创建cdc-ckafka集群
创建DIP转储任务
创建Datahub连接源
修改Datahub任务
编辑Datahub连接源
查询Datahub任务列表
查询Datahub任务信息
查询Datahub连接源列表
查询Datahub连接源
删除Datahub任务
删除Datahub连接源
数据结构
错误码
ckafkaCN API 2017
API 简介
API 概览
调用方式
签名方法
请求结构
请求结构简介
公共请求参数
接口请求参数
最终请求形式
返回结果
正确返回结果
错误返回结果
异步任务接口返回格式
主题相关接口
创建主题
修改主题属性
删除主题
增加分区
获取主题列表
获取主题属性
设置消息转发
实例相关接口
获取实例列表
获取实例属性
设置实例属性
查询消费分组信息
查询消费分组信息(精简版)
获取消费分组信息
获取消费分组 offset
设置消费分组 offset
访问控制相关接口
增加主题白名单
删除主题白名单
ACL 策略相关接口
添加用户
删除用户
修改密码
枚举用户信息
添加 ACL 策略
删除 ACL 策略
枚举 ACL 策略
数据同步相关接口
创建数据同步任务
启动数据同步任务
暂停数据同步任务
删除数据同步任务
获取数据同步任务列表
获取数据同步任务状态
获取数据同步任务配置
错误码
SDK 文档
SDK 概览
Java SDK
VPC 网络接入
VPC 网络 SASL_SCRAM 方式接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Python SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Go SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
PHP SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
C++ SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
Node.js SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
连接器相关 SDK
数据上报 SDK
弹性 Topic 收发消息 SDK
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
Filebeats 接入 CKafka
Logstash 接入 CKafka
通用参考
对 CKafka 进行生产和消费压力测试
常见参数配置说明
接入低版本自建 Kafka
CKafka 版本选择建议
CKafka 数据可靠性说明
连接器
数据库变更订阅
MongoDB 数据订阅
MySQL 数据订阅
PostgreSQL 数据订阅
MySQL 订阅消息官方格式说明
MySQL 订阅消息 canal 格式说明
连接器订阅 MySQL 的分区分表策略
连接器订阅 PostgreSQL 时用户权限设置参考
数据处理
数据处理规则说明
正则提取
JsonPath 说明
自建集群接入说明(CLB 方式)
连接器访问 CLS、COS 等服务的授权说明
什么是信令表
常见问题
实例问题
Topic 问题
Consumer Group 问题
客户端问题
网络问题
限流问题
监控问题
消息问题
概念问题
连接器问题
任务相关问题
数据上报相关问题
数据处理相关问题
数据转存相关问题
数据订阅相关问题
服务等级协议
联系我们
词汇表
文档中心
入门中心
API 中心
SDK 中心
我的文档中心
诚邀爱技术、爱分享的你,成为文档内容共建者>
HOT
请按回车键搜索本产品所有文档
请按回车键搜索本产品所有文档
查询
查看全部搜索结果
消息队列 CKafka
消息队列 CKafka(Cloud Kafka)是基于开源 Apache Kafka 消息队列引擎,提供高吞吐性能、高可扩展性的消息队列服务。消息队列 CKafka 完美兼容 Apache kafka 0.9、0.10、1.1、2.4、2.8版本接口,在性能、扩展性、业务安全保障、运维等方面具有超强优势,让您在享受低成本、超强功能的同时,免除繁琐运维工作。
产品动态
购买指南
02:07
2分钟带您认识消息队列 CKafka
了解
产品简介
产品概述
产品优势
应用场景
购买指南
计费概述
欠费说明
退费说明
快速入门
VPC 公网接入
公网域名接入
进阶实践
操作指南
添加路由策略
配置 ACL 策略
迁移数据上云
最佳实践
Spark Streaming 接入 CKafka
Kafka Connect 接入 CKafka
Logstash 接入 CKafka
通用参考
CKafka 数据可靠性说明
CKafka 版本选择建议
CKafka 常用参数配置指南
开发者资源
API 文档
简介
API 概览
错误码
SDK 文档
Java SDK
Python SDK
Go SDK
常见问题
CKafka 和 CMQ 有什么区别?
CKafka 是否支持公网访问?
消费异常如何排查?
消费组列表详情缺失如何处理?
出现消息堆积如何处理?
如何选取 CKafka 副本数?
查询
云服务器
网站备案
即时通信 IM
对象存储
计算
云服务器
轻量应用服务器
裸金属云服务器
GPU 云服务器
FPGA 云服务器
专用宿主机
云托付物理服务器
弹性伸缩
批量计算
高性能计算平台
本地专用集群
黑石弹性公网 IP
专属可用区
边缘可用区
自动化助手
高性能计算集群
软件服务
腾讯 Kona
TencentOS Server
计算加速套件 TACO Kit
边缘计算
边缘计算机器
物联网边缘计算平台
网络
负载均衡
私有网络
专线接入
云联网
弹性网卡
NAT 网关
对等连接
VPN 连接
网络流日志
Anycast 公网加速
共享带宽包
共享流量包
弹性公网 IPv6
弹性公网 IP
SD-WAN 接入服务
私有连接
CDN 与加速
内容分发网络 CDN
全站加速网络
安全加速 SCDN
全球应用加速
全球办公访问
全链路加速
网络安全
DDoS 基础防护
DDoS 高防包
DDoS 高防 IP
云防火墙
网络入侵防护系统
样本智能分析平台
高级威胁检测系统
边缘安全加速平台
终端安全
主机安全
iOA 零信任安全管理系统
企业移动管理
容器安全服务
微隔离服务
业务安全
服务性能测试
手游安全
风控平台
流量反欺诈
营销风控
验证码
天御业务安全防护
文本内容安全
图片内容安全
音频内容安全
视频内容安全
营销号码安全
业务风险情报
联邦学习
邮件证书
全栈式风控引擎
腾讯安心用户运营平台
应用合规平台
私域安全
流量风险决策平台
账号风控平台
设备安全
身份安全
数字身份管控平台(员工版)
多因子身份认证
安全管理
安全运营中心
安全运营中心(专有云)
安全服务
安全专家服务
高级威胁追溯系统
威胁情报云查服务
安全托管服务
网络空间云监测系统
应急响应服务
安全攻防对抗服务
重要时期安全保障服务
渗透测试服务
威胁情报中心
应用安全
Web 应用防火墙
iOA 应用安全访问服务
漏洞扫描服务
移动应用安全
小程序安全
软件定义边界
应用安全开发
二进制软件成分分析
API 安全治理
数据安全
数据安全中心
堡垒机
数据安全审计
数据脱敏
云加密机
密钥管理系统
凭据管理系统
数据保险箱
云访问安全代理
机密计算平台
通用解决方案
直播安全
品牌保护
智能票财税
腾讯安心平台
智能培练机器人
企业共享服务中心
行业解决方案
金融云
直播录制
在线教育互动课堂
沉浸式媒体
电商
微信解决方案
小程序 · 云直播
小程序 · 企业直播
用户服务
账号相关
控制台相关
消息中心
计费相关
购买指导
活动相关
服务计划
护航服务
联系我们
低代码
云开发 CloudBase
腾讯云微搭低代码
静态网站托管
云开发 CLI 工具
云托管 CloudBase Run
Web 应用托管
微服务
微服务引擎 TSE
弹性微服务
微服务平台 TSF
容器
容器服务
服务网格
容器镜像服务
云原生分布式云中心
中间件
消息队列 Pulsar 版
消息队列 CMQ 版
消息队列 RabbitMQ 版
消息队列 RocketMQ 版
消息队列 CKafka
API 网关
数据接入平台
Serverless
云函数
Serverless 应用中心
Serverless HTTP 服务
Serverless SSR
事件总线
视频服务
实时音视频
云直播
云点播
X-P2P
虚拟直播
视频终端
音视频终端 SDK(腾讯云视立方)
音视频通话 SDK
直播 SDK
短视频 SDK
腾讯特效 SDK
播放器 SDK
媒体处理
媒体处理
极速高清
智能识别
智能审核
智能编辑
云渲染
云游戏
云桌面
应用云渲染
内容创作
智能创作
正版曲库直通车
腾讯云智绘
VR 实景漫游
音速达直播音乐版权引擎
低代码开发
低代码互动课堂
数据分析
弹性 MapReduce
Elasticsearch Service
云数据仓库 PostgreSQL
云数据仓库 ClickHouse
云数据仓库 for Apache Doris
流计算 Oceanus
数据湖计算 DLC
数据集成
数据编排平台
数据应用与可视化
产业分析
腾讯云图数据可视化
隐私计算
大数据可视交互系统
智能推荐平台
移动推送
商业智能分析 BI
RayData 企业版
RayData 网页版
数据开发与治理
大数据处理套件
数据开发治理平台 WeData
金融服务
企业收付平台
云支付
金融专有云开发测试平台
供应链金融
企业金融服务平台
政务服务
智慧党建
腾讯数字农村
医疗服务
智能导诊
AI 就医助手
AI 临床助手
智能预问诊
医疗数据中台
医疗报告结构化
精准预约
医典内容库调用
建筑服务
微瓴物联网类操作系统
腾讯智慧建筑运营系统
腾讯智慧建筑 AI 能效
腾讯即视智慧视觉分析系统
微瓴软硬一体机
移动服务
腾讯客户端性能分析
ProWork 团队协同
内容智能分发
游戏服务
游戏多媒体引擎
科创服务
材料研究平台
教育服务
智聆口语评测
数学作业批改
英文作文批改
腾学汇
互动白板
AI 互动课开发套件
1+X 认证
云课堂
校企合作通
腾讯教育智脑
文旅服务
数字文博采集与建模
数字峰会平台
基础存储服务
对象存储
云硬盘
文件存储
归档存储
云 HDFS
数据加速器 GooseFS
数据处理与分析
日志服务
混合云存储
存储网关
存储一体机
备份一体机
并行文件一体机
数据迁移
迁移服务平台
云数据迁移
存储数据服务
智能媒资托管
数据协作平台
智能存储
智能视图计算平台
智能数据处理
数据万象
内容识别
数据万象图片服务
图片审核
图片处理
数据万象媒体服务
视频审核
音频审核
多媒体处理
数据万象文档服务
文本审核
文档审核
文档服务
物联平台服务
物联网开发平台
物联使能
物联网设备洞察
物联设备服务
物联网通信
腾讯物联网终端操作系统
物联网智能视频服务(行业版)
物联网智能视频服务(消费版)
物联网络管理服务
物联卡
LPWA 物联网络
高可用物联网卡
物联安全服务
物联网设备身份认证
域名与网站
域名注册
DNS 解析 DNSPod
网站备案
SSL 证书
证书监控 SSLPod
移动解析 HTTPDNS
私有域解析 Private DNS
代码签名证书
云证通
DNSPod
动效素材服务
云通信
即时通信 IM
短信
语音消息
邮件推送
号码认证
移动网络加速
远程实时操控
企业应用
腾讯企点客服
腾讯企点营销
智慧会务
账号连接器
数据连接器
腾讯优码
品牌经营管家
千帆神笔 aPaaS
腾讯问卷
腾讯电子签
多云管理
数字藏品营销平台
腾讯云 Mall
企业推
办公协同
腾讯会议
腾讯文档企业版
TAPD 敏捷项目管理
腾讯HR助手
腾讯企业邮
腾讯云统一门户
腾讯云企业网盘
腾讯云安灯
腾讯浏览服务
腾讯文档
区块链
腾讯云区块链服务平台 TBaaS
动产质押区块链登记系统
区块链可信取证
分布式身份
至信链版权存证
跨链服务平台
企业服务
商标注册
版权登记
增值电信
工商注册
网站建设
企业通信
云呼叫中心
能源服务
腾讯云综能工场
碳引擎
仿真云
工业服务
云端智造协同平台
云生态
云市场
产业互联网学堂
腾讯云开发者
渠道合作伙伴
更多
认证信息
政策与规范
分析师报告
词汇表
关系型数据库
TDSQL-C MySQL 版
TDSQL-C PostgreSQL 版
云数据库 MySQL
云数据库 MariaDB
云数据库 SQL Server
云数据库 PostgreSQL
NoSQL 数据库
云数据库 Redis
云数据库 MongoDB
云数据库 Memcached
时序数据库 CTSDB
游戏数据库 TcaplusDB
云数据库 Tendis
图数据库 KonisGraph
云数据库 KeeWiDB
数据库 SaaS 服务
数据传输服务
数据库专家服务
数据库智能管家 DBbrain
数据库审计
数据库管理
数据库备份服务
企业级分布式数据库
TDSQL MySQL版
TDSQL PostgreSQL版
TDSQL-A PostgreSQL版
TDSQL-H LibraDB
TDSQL-A ClickHouse 版
数据库软硬一体
数据库一体机 TData
云数据库独享集群
数据库分布式云
数据库分布式云中心
人脸与人体识别
人脸识别
人脸核身
人脸支付
换脸甄别
AI 智能测评解决方案
人体分析
智能内容生成与处理
人脸融合
人脸试妆
人像变换
文字识别
文字识别
智能扫码
营业执照核验
增值税发票核验
智能结构化
办公文档还原
语音技术
语音识别
语音合成
音色变换
声音定制
AI 平台服务
TI-ONE 训练平台
腾讯智能对话平台
腾讯云小微数智人
TI-ACC 加速工具
腾讯觅影开放实验平台
腾讯灯塔智能数据洞察
AI 行业应用
智能保险助手
智能合同审核
搜狗输入法企业版
图像分析与处理
图像识别
图像搜索
图像处理
图像标签
智能机器人
腾讯云小微
智能硬件 AI 语音助手
对话机器人
腾讯同传系统
自然语言处理
自然语言处理
机器翻译
腾讯知识图谱
媒体智能
媒体智能标签
应用程序集成
应用与服务编排工作流
开发者工具
标准兼容测试
专家兼容测试
远程调试
手游安全测试
代码托管
项目管理
测试管理
持续集成
制品库
持续部署
移动开发平台
云端 IDE
腾讯云代码分析
云资源管理
腾讯云助手
云 API
命令行工具
资源编排 TIC
云顾问
API 中心
SDK 中心
标签
地域管理系统
云资源自动化 for Terraform
监控与运维
云监控
Prometheus 监控服务
云拨测
应用性能观测
前端性能监控
云压测
混沌演练平台
Grafana 可视化服务
设计协同管理工具
设计协作平台
管理与审计
访问管理
云审计
账号威胁发现
集团账号管理
商业流程服务
配置审计
安全凭证服务
私有云
腾讯专有云企业版
TDSQL MySQL 版(私有云)
微服务平台 TSF(私有云)
更多
本页目录
消息队列 CKafka
关闭
目录
文档首页
关闭
消息队列 CKafka
动态与公告
新功能发布记录
连接器发布记录
Broker 版本升级记录
产品简介
产品概述
产品优势
应用场景
技术原理
开源对比
使用限制
地域和可用区
购买指南
产品规格
计费概述
包年包月
按量计费
购买方式
欠费说明
退费说明
快速入门
入门流程指引
获取访问授权
VPC 网络接入
步骤1:创建实例
步骤2:创建 Topic
步骤3:添加 VPC 网络路由
步骤4:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
公网域名接入
步骤1:创建实例
步骤2:添加公网路由
步骤3:创建 Topic
步骤4:配置 ACL 策略
步骤5:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
操作指南
实例管理
创建实例
批量连续命名或指定模式串命名
查看实例
升配实例
销毁/退还实例
升级实例版本
添加路由策略
公网带宽管理
接入外部监控 Prometheus
迁移可用区
设置系统维护时间
配置消息大小
Topic 管理
实例 Topic
创建 Topic
查看 Topic
删除 Topic
发送消息
设置 Topic 限流规则
弹性 Topic
Topic 管理
订阅管理
Consumer Group
概述
创建 Consumer Group
查询 Consumer Group
删除 Consumer Group
设置 Offset
自动重置 offset
连接器
连接器简介
连接器概述
连接器优势
应用场景
技术原理
使用限制
连接管理
任务管理
新建数据接入任务
HTTP 上报
对象存储 COS
数据传输服务 DTS
MariaDB 数据订阅
MongoDB 数据订阅
MySQL 数据订阅
MySQL 数据接入
PostgreSQL 数据订阅
SQL Server 数据订阅
TDSQL-C MySQL 数据订阅
TDSQL-C PostgreSQL 数据订阅
新建数据流出任务
数据目标
消息队列 CKafka
数据仓库(ClickHouse)
时序数据库(CTSDB)
日志服务(CLS)
对象存储(COS)
分析型数据库 Doris
Elasticsearch Service
事件总线(Event Bridge)
数据库 MySQL
PostgreSQL
云数据仓库-PostgreSQL
TDSQL-C PostgreSQL
TDSQL PostgreSQL 版
分布式数据仓库(TDW)
简单数据处理
数据解析
解析内部 JSON 结构
日期格式处理
字段修改
数据转换
正则表达式自动生成
过滤器规则说明
任务编排
Schema 管理
管理任务
查看监控
查看消息
事件中心
监控告警
查看监控信息
查询高级监控(专业版)
配置告警
告警配置建议
查看高级运维特性(专业版)
智能运维
一键诊断
弹性伸缩
磁盘水位处理
分区动态处理
权限管理
配置 ACL 策略
访问管理 CAM
标签管理
标签概述
使用标签
编辑标签
查询消息
事件中心
迁移上云
迁移方案概述
步骤1:购买云上实例
步骤2:迁移 Topic 上云
步骤3:迁移数据上云
方案1:单写双消费迁移
方案2:单写单消费迁移
方案3:使用 Mirrormaker 迁移
方案4:迁移未消费数据
集群备份
数据压缩
最佳实践
连接器最佳实践
HTTP 上报
HTTP 协议接入 Kafka
统一数据上报
数据库变更订阅查询
Mongo Stream 数据变更记录分析
MySQL 数据变更记录分析
PostgreSQL 数据变更记录分析
MySQL 到 Elasticsearch 实时数据同步
PostgreSQL 到 Elasticsearch 实时数据同步
替换 Canal 实现 MySQL 数据库订阅
数据简单清洗
日志采集处理查询
TKE 日志
Flink 接入 CKafka
Schema Registry 接入 CKafka
Spark Streaming 接入 CKafka
Flume 接入 CKafka
Kafka Connect 接入 CKafka
Storm 接入 CKafka
Logstash 接入 CKafka
Filebeat 接入 CKafka
跨可用区部署
生产消费最佳实践
日志接入
日志服务 CLS
容器服务(TKE) 日志
云防火墙日志
安全运营中心
日志检索
WAF 日志投递
替换支撑路由(旧)
故障处理
Topic 相关故障
Topic 创建失败
Topic 无监控数据
Topic 配置 ACL 策略后导致其他产品联动能力失效
分区的监控查看消息堆积数量一直存在
Consumer Group 相关故障
Consumer Group 列表详情缺失
Consumer Group 持续出现 PreparingRebalance 状态
客户端相关故障
客户端常见报错与解决方案
客户端生产消息进入到阻塞状态
客户端消费不到消息
Sarama 客户端异常
消息相关故障
消费数据异常
过期消息没有被及时删除
消费速度缓慢
出现消息堆积的警告
生产一段时间后发现持续性错误
API 文档
更新历史
简介
API 概览
调用方式
请求结构
公共参数
签名方法 v3
签名方法
返回结果
参数类型
实例相关接口
设置实例属性
设置Groups 消费分组offset
获取实例列表详情
获取实例列表信息
获取实例属性
获取消费分组offset
获取消费分组信息
创建实例(预付费包年包月)
删除预付费实例
删除消费组
预付费实例变配接口
获取Datahub消费分组offset
Ckafka询价
创建按量计费实例
主题相关接口
设置主题属性
获取主题列表详情
获取主题属性
获取主题列表
删除主题IP白名单
删除主题
创建主题IP白名单
创建主题
增加主题分区
根据位点查询消息列表
查询消息
查询订阅某主题消息分组信息
批量设置主题属性
批量修改消费组offset
创建消费者组
查询cdc任务接口
查询Datahub Topic最新消息列表
查询Datahub Topic消息
删除Datahub主题
查询topic生产端连接信息
获取Topic 同步副本信息
ACL相关接口
修改密码
查询用户信息
枚举ACL
删除用户
删除ACL
添加用户
添加 ACL 策略
删除ACL规则
批量添加 ACL 策略
路由相关接口
查看路由信息
添加实例路由
删除路由
Datahub 相关接口
HTTP发送消息
其他接口
枚举消费分组(精简版)
查询消费分组信息
查询用户列表
枚举地域
查看可用区列表
修改路由触发时间
创建token
取消授权token
实例授权token
创建cdc-ckafka集群
创建DIP转储任务
创建Datahub连接源
修改Datahub任务
编辑Datahub连接源
查询Datahub任务列表
查询Datahub任务信息
查询Datahub连接源列表
查询Datahub连接源
删除Datahub任务
删除Datahub连接源
数据结构
错误码
ckafkaCN API 2017
API 简介
API 概览
调用方式
签名方法
请求结构
请求结构简介
公共请求参数
接口请求参数
最终请求形式
返回结果
正确返回结果
错误返回结果
异步任务接口返回格式
主题相关接口
创建主题
修改主题属性
删除主题
增加分区
获取主题列表
获取主题属性
设置消息转发
实例相关接口
获取实例列表
获取实例属性
设置实例属性
查询消费分组信息
查询消费分组信息(精简版)
获取消费分组信息
获取消费分组 offset
设置消费分组 offset
访问控制相关接口
增加主题白名单
删除主题白名单
ACL 策略相关接口
添加用户
删除用户
修改密码
枚举用户信息
添加 ACL 策略
删除 ACL 策略
枚举 ACL 策略
数据同步相关接口
创建数据同步任务
启动数据同步任务
暂停数据同步任务
删除数据同步任务
获取数据同步任务列表
获取数据同步任务状态
获取数据同步任务配置
错误码
SDK 文档
SDK 概览
Java SDK
VPC 网络接入
VPC 网络 SASL_SCRAM 方式接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Python SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Go SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
PHP SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
C++ SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
Node.js SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
连接器相关 SDK
数据上报 SDK
弹性 Topic 收发消息 SDK
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
Filebeats 接入 CKafka
Logstash 接入 CKafka
通用参考
对 CKafka 进行生产和消费压力测试
常见参数配置说明
接入低版本自建 Kafka
CKafka 版本选择建议
CKafka 数据可靠性说明
连接器
数据库变更订阅
MongoDB 数据订阅
MySQL 数据订阅
PostgreSQL 数据订阅
MySQL 订阅消息官方格式说明
MySQL 订阅消息 canal 格式说明
连接器订阅 MySQL 的分区分表策略
连接器订阅 PostgreSQL 时用户权限设置参考
数据处理
数据处理规则说明
正则提取
JsonPath 说明
自建集群接入说明(CLB 方式)
连接器访问 CLS、COS 等服务的授权说明
什么是信令表
常见问题
实例问题
Topic 问题
Consumer Group 问题
客户端问题
网络问题
限流问题
监控问题
消息问题
概念问题
连接器问题
任务相关问题
数据上报相关问题
数据处理相关问题
数据转存相关问题
数据订阅相关问题
服务等级协议
联系我们
词汇表
搜索
取消
清除
查询
已找到本产品下“
”的记录
若干
条