简介

最近更新时间:2025-09-18 01:22:00

我的收藏

概述

消息队列 CKafka 版(TDMQ for CKafka)是一个分布式、高吞吐量、高可扩展性的消息系统,100%兼容开源 Kafka API 2.4、2.8、3.2 版本。CKafka 基于发布/订阅模式,通过消息解耦,使生产者和消费者异步交互,无需彼此等待。CKafka 具有高可用、数据压缩、同时支持离线和实时数据处理等优点,适用于日志压缩收集、监控数据聚合、流式数据集成等场景。
本章节介绍的 TDMQ CKafka 版 API 接口均为 API 3.0接口。
您可以调用 API 对 CKafka 进行操作,例如创建实例、创建 Topic、收发消息等。
CKafka 支持的所有接口信息,请参见 API 概览

术语表

CKafka API 接口的常见术语请参见下表:

术语 描述
实例 消息队列 CKafka 版中,实例(Instance)是购买 CKafka 的单位。按照峰值吞吐量(MB/s)、磁盘容量(GB)的不同,将实例分为不同规格。购买不同规格的实例,以保证 CKafka 的高可靠和高可用,默认购买的是高可用的集群服务,服务中包含多个 Broker 服务器,且客户无需关心硬件设备。
主题 主题(Topic)是用于存储消息的逻辑概念,可以看做一个消息集合。每个 Topic 可以有多个生产者向其中推送(push)消息,也可以有任意多个消费者消费其中的消息。
生产者 生产者(Producer)指在消息队列中担任发送消息的角色。
消费者 消费者(Consumer)是从 Topic 中拉取消息,并对消息进行消费的服务。消费者将自行维护其消费到 Partition 的 offset 的相关信息。
消费者分组 消费者分组(Consumer Group)是消费者的集合,在 CKafka 中,多个 Consumer 可以组成一个 Consumer Group,且一个 Consumer 只能属于一个 Consumer Group。Consumer Group 保证其订阅 Topic 的每个分区只被分配给该 Consumer Group 中的一个 Consumer 处理。

其他相关术语可参考 词汇表

使用限制

  • CKafka 的使用限制请参见 CKafka使用限制
  • 对于具体的参数限制,请参考各接口文档中的参数说明。

API 快速入门

您可以使用 API Explorer 工具在线调用 API。
本文以将创建 CKafka 实例等资源、使用为例,通过 API Explorer 工具调用 API 接口的步骤如下:
1.进入 API Explorer 工具页面。更多 API Explorer 工具使用信息,请参见使用 API Explorer
2.调用CreateTopic接口,在实例下创建 Topic。
3.调用CreateRoute接口,给实例添加添加 VPC 路由。
4.调用CreateUser接口,创建一个用户。
5.调用CreateAcl接口,添加一条 ACL 策略。
6.使用客户端收发消息(本操作不支持通过 API 接口完成)。
7.调用FetchMessageByOffset 接口,查询消息。