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 相关
客户端相关
网络问题
监控相关
消息相关
服务协议
服务等级协议
联系我们
词汇表

Introduction

PDF
聚焦模式
字号
最后更新时间: 2025-12-29 11:41:28

Overview
TDMQ for CKafka is a distributed, high I/O throughput, highly scalable messaging system, 100% compatible with open-source Kafka API versions 2.4, 2.8, and 3.2. Based on the publish/subscribe model, CKafka decouples messages, allowing producers and consumers to interact asynchronously without the need to wait. With high availability, data compression, and simultaneous support for offline and real-time data processing, CKafka is suitable for scenarios such as log compression collection, monitoring data aggregation, and streaming data integration.
This section introduces TDMQ for CKafka API interfaces, which are all API 3.0 interfaces.
You can call APIs to operate CKafka, such as create instance, create Topic, and send/receive messages.
For all APIs supported by CKafka, please refer to the API overview.

Glossary

Common terminology for CKafka API interface see the table below:

Term Description
In TDMQ for CKafka, an Instance is the unit of purchase. Instances are divided into different specifications by peak throughput (MB/s) and disk capacity (GB). Purchase instances of varying specifications to ensure high reliability and availability of CKafka. By default, the purchased cluster service is highly available, containing multiple Broker servers, and customers do not need to worry about hardware devices.
A Topic is a logical concept used to store messages, which can be viewed as a message collection. Each Topic can have multiple producers pushing messages to it, and any number of consumers can consume the messages.
Producer (Producer) refers to the role that sends messages in a message queue.
A Consumer is a service that pulls messages from a Topic and consumes them. The Consumer maintains the relevant information of the offset it consumes to the Partition.
A Consumer Group is a collection of consumers. In CKafka, multiple consumers can form a Consumer Group, and a Consumer can only belong to one Consumer Group. A Consumer Group ensures that each partition of the subscribed Topic is assigned to only one Consumer in the Group for processing.

For other relevant terminology, see the glossary (https://www.tencentcloud.com/document/product/597/32544?from_cn_redirect=1).

Usage limits
-For CKafka usage limits, please refer to CKafka Usage Limits.
-For specific parameter limits, refer to the parameter descriptions in each API document.

Getting Started with APIs

You can use the API Explorer tool to call APIs online.
This document uses creating a CKafka instance and other resources as an example. The steps for API calls via the API Explorer Tool are as follows:

  1. Go to the API Explorer tool page. For more information about API Explorer tool usage, see Using API Explorer.
    Call the CreateTopic API (https://www.tencentcloud.com/document/product/597/40851?from_cn_redirect=1) to create a topic under the instance.
  2. Call the CreateRoute API to add VPC routing to the instance.
  3. Call the CreateUser API to create a user.
  4. Call the CreateAcl API to add an ACL policy.
  5. Use client to send/receive messages (This operation cannot be performed through API interface).
  6. Call the FetchMessageByOffset API to query messages.

帮助和支持

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

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

文档反馈