Tencent Cloud

Recent Pages

Topic 管理

最后更新时间：2024-05-30 18:17:11

操作场景
Topic（主题）是某一种分类的名字，消息在 Topic 中可以被存储和发布，生产者往 Topic 中写消息，消费者从 Topic 中读消息。为了做到水平扩展，一个 Topic 实际是由多个 Partition（分区）组成，遇到瓶颈时，可以通过增加 Partition 的数量进行横向扩容。Topic 是连接器订阅和发布的最小单位，用户可以用 Topic 来表示一类或者一种流数据。
CKafka 支持弹性 Topic 类型，您可以在控制台直接创建弹性 Topic 并且不需要先购买 CKafka 实例，使用弹性 Topic，您同样可以使用 SDK 完成消息收发，同时也可以将弹性 Topic 作为数据任务的数据源或者数据目标。
说明：
当前弹性 Topic 暂未开启计费，后续开启收费将会提前通知您。
使用限制
单弹性 Topic 支持的分区数量上限为500个，弹性 Topic 带宽无默认大小，带宽建议使用不要超过500M。
弹性 Topic 支持最大消息大小为 12MB。
操作步骤
创建 Topic
1. 登录 CKafka 控制台。
2. 在左侧导航栏单击弹性 Topic，选择好地域后，单击新建 Topic。
3. 填写 Topic 信息后，单击确定，完成 Topic 创建。
Topic 名称：Topic 名称由“appid-[用户输入的名称]”构成，用户输入的名称只能包含字母、数字、下划线、“-”、“.”。
备注：选填，Topic 备注信息。
分区数：一个物理上分区的概念，一个 Topic 可以包含一个或者多个 Partition，CKafka 以 Partition 作为分配单位。单个 Topic 支持最大分区数：500。
消息保留时间：范围1分钟到90天。在磁盘容量不足（即磁盘水位达到90%）时，将会提前删除旧的消息，以确保服务可用性。
﻿
查询 Topic
在 弹性 Topic 列表右上角的搜索框中，通过 Topic 名称进行搜索查询，连接器将会模糊匹配并呈现搜索结果。
编辑 Topic
1. 在 弹性 Topic 列表中，找到需要编辑的 Topic ，单击操作栏中的编辑。
2. 在弹出的对话框中可以对 Topic 的备注，分区数和消息保留时间进行修改。
3. 单击确认即完成对 Topic 的编辑。
发送消息
CKafka 控制台支持手动发送消息，在控制台进行相应的操作即可实现消息发送给指定的 Topic 。
1. 在 弹性 Topic 列表中，找到需要发送消息的 Topic ，单击操作列中的发送消息。
2. 在弹出的对话框中输入消息内容和消息 key，同时您也可以将消息发送到指定分区。
﻿
3. 单击确认，完成消息的发送。消息发送后即可被 Topic 下的任意订阅者消费。
新增订阅
支持手动创建订阅，在控制台进行相应的操作后即可完成订阅的创建。
1. 在 弹性 Topic 列表中，找到需要创建订阅的 Topic ，单击 Topic 的 ID 进入 Topic 基本信息页面。
2. 在页面上方选择订阅关系页签，单击新建订阅关系，在弹出的对话框中输入消费者名称。
﻿
3. 单击提交完成创建，即可在列表中看到刚刚创建的订阅。
删除 Topic
注意：
删除了 Topic 之后也会清除该 Topic 下积累的未消费消息，请谨慎执行。
1. 在 弹性 Topic 列表中，找到需要删除的 Topic ，单击操作列中的删除。
2. 在弹出的提示框中，单击删除，完成删除。
﻿