tencent cloud

消息队列 CKafka 版

动态与公告

新功能发布记录

Broker 版本升级记录

连接器发布记录

Datahub 新功能发布记录

公告

弹性 Topic 功能计划终止公测公告

消息队列 CKafka 高级版上线公告

产品简介

技术原理

Consumer Group 状态说明

限流机制说明

地域和可用区

高可用

多可用区部署

多副本及选举机制

数据高可靠

迁移可用区

购买指南

专业版 - 弹性存储

计费概述

按量计费实例转包年包月

快速入门

入门流程指引

获取访问授权

子账号获取访问授权

授予子账号操作级权限

授予子账号资源级权限

授予子账号标签级权限

VPC 网络接入

步骤1：创建实例

步骤2：创建 Topic

步骤3：添加 VPC 网络路由

步骤4：收发消息

使用 SDK 收发消息（推荐）

运行 Kafka 客户端（可选）

公网域名接入

步骤1：创建实例

步骤2：添加公网路由

步骤3：创建 Topic

步骤4：配置 ACL 策略

步骤5：收发消息

使用 SDK 收发消息（推荐）

运行 Kafka 客户端（可选）

开发指南

CKafka 事务管理

CKafka 版本选择建议

CKafka 常见参数配置说明

CKafka 数据压缩

接入低版本自建 Kafka

操作指南

实例管理

批量连续命名或指定模式串命名

销毁/退还实例

按量计费实例转包年包月

升级实例版本

添加路由策略

接入外部监控 Prometheus

迁移可用区

设置系统维护时间

配置消息大小

Topic 管理

实例 Topic

设置 Topic 限流规则

弹性 Topic

Consumer Group

创建 Consumer Group

查询 Consumer Group

删除 Consumer Group

自动重置 offset

监控告警

查看监控信息

查询高级监控（专业版）

告警配置建议

查看高级运维特性（专业版）

智能运维

弹性伸缩

磁盘水位处理

分区动态处理

权限管理

配置 ACL 策略

访问管理 CAM

迁移上云

迁移方案概述

步骤1：购买云上实例

步骤2：迁移 Topic 上云

步骤3：迁移数据上云

方案1：单写双消费迁移

方案2：单写单消费迁移

方案3：使用 Mirrormaker 迁移

方案4：迁移未消费数据

CKafka 连接器

连接器简介

连接器概述

连接器优势

连接管理开放网段

任务管理

新建数据接入任务

对象存储 COS

数据传输服务 DTS

新建数据流出任务

数据目标

数据仓库（ClickHouse）

日志服务（CLS）

对象存储（COS）

Elasticsearch Service

TDSQL-C PostgreSQL

分布式数据仓库（TDW）

简单数据处理

过滤器规则说明

实践教程

CKafka 客户端实践教程

生产消费实践教程

Confluent Go SDK

Kafka Python SDK

连接器实践教程

HTTP 上报

HTTP 协议接入 Kafka

统一数据上报

数据库变更订阅查询

Mongo Stream 数据变更记录分析

数据简单清洗

Flink 接入 CKafka

Schema Registry 接入 CKafka

Spark Streaming 接入 CKafka

Flume 接入 CKafka

Kafka Connect 接入 CKafka

Storm 接入 CKafka

Logstash 接入 CKafka

Filebeat 接入 CKafka

日志接入

日志服务 CLS

替换支撑路由（旧）

高 CPU 场景下集群带宽实践教程

集群容量规划实践教程

故障处理

Topic 相关故障

Topic 创建失败

Topic 无监控数据

Topic 配置 ACL 策略后导致其他产品联动能力失效

分区的监控查看消息堆积数量一直存在

Consumer Group 相关故障

Consumer Group 列表详情缺失

Consumer Group 持续出现 PreparingRebalance 状态

客户端相关故障

客户端常见报错与解决方案

客户端生产消息进入到阻塞状态

客户端消费不到消息

Sarama 客户端异常

消息相关故障

消费数据异常

过期消息没有被及时删除

消费速度缓慢

出现消息堆积的警告

生产一段时间后发现持续性错误

API 文档

Making API Requests

Request Structure

DataHub APIs

DescribeDatahubTopics

ACL APIs

DescribeAclRule

Topic APIs

Instance APIs

CreatePostPaidInstance

CreateInstancePost

DescribeInstances

DeleteInstancePre

DescribeGroupInfo

DescribeGroupOffsets

DescribeInstanceAttributes

DescribeInstancesDetail

InquireCkafkaPrice

ModifyGroupOffsets

ModifyInstanceAttributes

ModifyInstancePre

Route APIs

DescribeTaskStatus

Other APIs

DeleteRouteTriggerTime

DescribeAppInfo

DescribeCkafkaZone

DescribeConsumerGroup

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

Filebeats 接入 CKafka

Logstash 接入 CKafka

通用参考

对 CKafka 进行生产和消费压力测试

常见参数配置说明

接入低版本自建 Kafka

CKafka 版本选择建议

CKafka 数据可靠性说明

连接器

数据库变更订阅

MongoDB 数据订阅

MySQL 数据订阅

PostgreSQL 数据订阅

MySQL 订阅消息官方格式说明

MySQL 订阅消息 canal 格式说明

连接器订阅 PostgreSQL 时用户权限设置参考

数据处理

数据处理规则说明

JsonPath 说明

自建集群接入说明（CLB 方式）

连接器访问 CLS、COS 等服务的授权说明

什么是信令表

常见问题

Consumer Group 问题

客户端问题

连接器问题

任务相关问题

数据上报相关问题

数据处理相关问题

数据转存相关问题

数据订阅相关问题

服务等级协议

文档消息队列 CKafka 版

消息队列 CKafka 版

查看产品介绍

消息队列 CKafka 版

查看产品介绍

动态与公告

产品简介

高可用

购买指南

快速入门

开发指南

操作指南

CKafka 连接器

实践教程

故障处理

API 文档

SDK 文档

通用参考

常见问题

服务等级协议

服务等级协议

联系我们

联系我们

词汇表

词汇表

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

您也可以联系销售或提交工单以寻求帮助。

是

否

联系我们

联系我们，为您的业务提供专属服务。

技术支持

如果你想寻求进一步的帮助，通过工单与我们进行联络。我们提供7x24的工单服务。

7x24 电话支持