Skip to main content

管理 Topic

本文介绍 Topic 的基本概念、相关约束以及 Topic 相关的创建、查看、变更和删除操作。

创建 Topic​

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Topic ，然后在 Topic 列表页面单击新建 Topic 。

  3. 在新建 Topic 的表单页面中填写名称、分区数、消息清理策略，然后单击确定， 完成创建。

如果实例开启了自动创建 Topic， 则会在生产消息或者订阅消息时自动触发 Topic 的创建。生产环境建议使用控制台或者 Kafka Admin API 进行 Topic 管理，避免自动创建带来的失控风险。

查看 Topic 详情​

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Topics ，然后在Topic 列表页面找到目标 Topic。

  3. 点击目标 Topic，进入 Topic 内部，查看概要信息、订阅信息和相关 Metrics 数据。

查询消息​

AutoMQ Kafka 支持在控制台直接查询消息。查询条件和参数如下：

  • 根据相对时间：在选定多个分区时，支持按相对时间查询消息。

  • 根据相对位点：在选定单个分区的时候，可以指定位点查询消息。

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Topics ，然后在Topic 列表页面找到目标 Topic。

  3. 点击目标 Topic，进入 Topic 内部，点击消息查询，输入相关的过滤条件查询消息列表。

删除 Topic​

删除 Topic 后，Topic 内的所有消息和配置都会被清理，无法恢复。因此首先需要确认业务不再使用。

如果实例开启了自动创建 Topic， 在生产消息或者订阅消息时自动触发 Topic 的重新创建。生产环境建议使用控制台或者 Kafka Admin API 进行 Topic 管理，避免自动创建带来的失控风险。

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Topics ，然后在Topic 列表页面找到目标 Topic。

  3. 点击右侧操作按钮，点击删除，完成二次确认后删除。