创建 Topic
操作步骤
- 登录环境控制台,在左侧导航栏单击实例列表 。然后在实例列表中,单击目标实例名称,进入实例内部功能。
- 在左侧导航栏单击Topic ,然后在Topic 列表页面单击新建Topic 。
- 在新建Topic 的表单页面中填写名称、分区数、消息清理策略,然后单击确定, 完成创建。
如果实例开启了自动创建 Topic, 则会在生产消息或者订阅消息时自动触发 Topic 的创建。生产环境建议使用控制台或者 Kafka Admin API 进行 Topic 管理,避免自动创建带来的失控风险。
查看 Topic 详情
操作步骤
- 登录环境控制台,在左侧导航栏单击实例列表 。然后在实例列表中,单击目标实例名称,进入实例内部功能。
- 在左侧导航栏单击Topics ,然后在Topic 列表页面找到目标 Topic。
- 点击目标 Topic,进入 Topic 内部,查看概要信息、订阅信息和相关 Metrics 数据。
查询消息
AutoMQ Kafka 支持在控制台直接查询消息。查询条件和参数如下:- 根据相对时间:在选定多个分区时,支持按相对时间查询消息。
- 根据相对位点:在选定单个分区的时候,可以指定位点查询消息。
操作步骤
- 登录环境控制台,在左侧导航栏单击实例列表 。然后在实例列表中,单击目标实例名称,进入实例内部功能。
- 在左侧导航栏单击Topics ,然后在Topic 列表页面找到目标 Topic。
- 点击目标 Topic,进入 Topic 内部,点击消息查询,输入相关的过滤条件查询消息列表。
删除 Topic
删除 Topic 后,Topic 内的所有消息和配置都会被清理,无法恢复。因此首先需要确认业务不再使用。如果实例开启了自动创建 Topic, 在生产消息或者订阅消息时自动触发 Topic 的重新创建。生产环境建议使用控制台或者 Kafka Admin API 进行 Topic 管理,避免自动创建带来的失控风险。
操作步骤
- 登录环境控制台,在左侧导航栏单击实例列表 。然后在实例列表中,单击目标实例名称,进入实例内部功能。
- 在左侧导航栏单击Topics ,然后在Topic 列表页面找到目标 Topic。
- 点击右侧操作按钮,点击删除,完成二次确认后删除。