SDK 概览

新功能发布记录

Broker 版本升级记录

弹性存储（专业版）价格调整公告

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

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

公告

动态与公告

TDMQ 产品系列介绍与选型	

什么是消息队列 CKafka 版

产品优势

应用场景

技术架构

能力对比

选型建议

TDMQ 产品系列介绍与选型

开源 Kafka 版本支持说明

与开源 Kafka 对比

集群高可靠

数据高可靠

高可用

使用限制

地域和可用区

产品简介

计费概述

内网带宽

存储

Partition

连接器

价格说明

计费示例

按小时付费转包年包月

续费说明

查看消费明细

欠费说明

退费说明

产品计费

入门流程指引

准备工作

步骤1：创建实例

步骤2：添加 VPC 网络路由

步骤3：创建 Topic

步骤4：收发消息

步骤5：查询消息

步骤6：销毁资源

VPC 网络接入

步骤1：创建实例	

步骤2：添加公网路由	

步骤3：创建 Topic	

步骤4：配置 ACL 策略

步骤5：收发消息

步骤6：查询消息

步骤7：销毁资源

公网域名接入

快速入门

使用流程指引

账号权限管理概述

授予子账号访问其他云产品权限

授予子账号操作级权限

授予子账号资源级权限

授予子账号标签级权限

配置账号权限

创建实例

创建 Topic

配置 ACL 策略

管理 Topic

配置 Topic

配置网络连接

配置自定义 SSL 证书

配置 ACL 用户

配置客户端参数

使用控制台发送消息

使用客户端收发消息

连接实例

查询消息

配置消息大小

配置消息保留机制

管理消息

创建消费组

查看消费组详情

消费组状态说明

查看和手动重置消费进度

自动重置消费进度

配置空消费组自动清理时长

手动删除消费组

取消消费组和 Topic 的订阅关系

管理消费组

查看和修改实例基本信息

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

配置系统维护时间

配置资源标签

配置实例销毁保护

销毁/退还实例

管理实例

变更实例规格

升级实例内核小版本

变更实例可用区

限流机制说明

配置限流规则

配置限流

配置磁盘水位处理策略

配置 Topic 分区均衡

开启弹性存储

开启弹性带宽

配置弹性伸缩策略

配置事务消息

压缩数据

配置高级特性

监控告警能力概述

查看监控数据

监控指标明细

配置告警策略

接入 Prometheus 监控

查看事件记录

开启一键诊断

查看监控和配置告警

连接器概述

配置 Kafka 之间的数据同步

配置 Kafka 数据同步至 Elasticsearch Service

数据处理规则解析

管理数据同步任务

查看消息

使用连接器同步数据

用户指南

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

集群容量规划实践教程

集群资源评估

生产消费实践教程

Confluent Go SDK

Sarama Go

Java SDK

Kafka Python SDK

ibrdkafka SDK

tRpc Go SDK

Kafka Client Rebalance 技术详解

接入低版本自建 Kafka

客户端实践教程

日志接入

腾讯云生态对接

Flink 接入 CKafka

Schema Registry 接入 CKafka

Spark Streaming 接入 CKafka

Flume 接入 CKafka

Kafka Connect 接入 CKafka

Storm 接入 CKafka

Logstash 接入 CKafka

Filebeat 接入 CKafka

开源生态对接

HTTP 上报

数据库变更订阅查询

数据简单清洗

连接器实践教程

替换支撑路由（旧）

实践教程

迁移方案概述

步骤1：购买云上实例

步骤2：迁移 Topic 上云

步骤3：迁移数据上云

使用开源工具迁移集群

迁移集群

客户端生产消息时延高

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

客户端消费不到消息

Sarama 客户端异常

客户端相关

消费数据异常

消费速度缓慢

出现消息堆积的警告

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

消息相关

故障处理

History

Introduction

API Category

Request Structure

Common Params

Signature v3

Signature

Responses

Making API Requests

DeleteRouteTriggerTime

DescribeAppInfo

DescribeCkafkaVersion

DescribeCkafkaZone

DescribeConsumerGroup

DescribeGroup

DescribeRegion

UpgradeBrokerVersion

Other APIs

BatchCreateAcl

CreateAcl

CreateAclRule

CreateUser

DeleteAcl

DeleteAclRule

DeleteUser

DescribeACL

DescribeAclRule

DescribeUser

ModifyPassword

ACL APIs

API 文档

消息队列 CKafka 版

SDK 类型	文档
Java SDK	VPC 网络接入公网 SASL_PLAINTEXT 方式接入公网 SASL_SSL 方式接入 VPC 网络 SASL_SCRAM 方式接入
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 方式接入

网络	VPC 网络	公网域名接入
协议	PLAINTEXT SASL_PLAINTEXT SASL_SSL（专业版支持）	SASL_PLAINTEXT SASL_SSL（专业版支持）

tencent cloud