如何处理不活跃的Topic

概述

本文主要介绍如何处理历史Topic或不活跃的Topic,以减少资源占用量。

详细信息

请先判断Topic的活跃状况,对于不活跃的Topic,您可以考虑进行删除,具体步骤如下。

判断Topic的活跃状况

判断Topic是否活跃主要依靠下列2个关键指标。

当前服务器上消息总量(TotalCount) 消息最后更新时间(LastTimeStamp)
一般情况下,如果消息总量为0,说明Topic不活跃。

一般情况下,如果消息最后更新时间是很久之前的有效时间戳,说明Topic不活跃。

说明:如果消息最后更新时间为0或者负值,说明系统没有获取到时间戳,请勿标记为不活跃的Topic,忽略即可。

上述2个关键指标可通过下列2种方式获取:

通过管理控制台查看Topic信息

通过OpenAPI批量查询Topic信息

  1. 登录消息队列Kafka版控制台
  2. 在顶部菜单栏,选择地域。
  3. 在左侧导航栏,单击实例管理,单击需要查询的Kafka实例名称。
  4. 在实例详情页面,单击左侧导航栏中的Topic管理
  5. Topic管理页面,找到目标Topic,在其操作列中单击分区状态
  6. 判断此Topic是否活跃。如果存在不活跃的Topic,请先记录Topic的名称,然后参考下文删除不活跃的Topic。
  1. 调用GetTopicList接口获取所有Topic信息。关于如何调用此接口,请参见GetTopicList
  2. 调用GetTopicStatus接口获取各Topic的消息收发状态。关于如何调用此接口,请参见GetTopicStatus
  3. 记录返回结果中各Topic的LastTimeStampTotalCount值。
  4. 参考上述内容,判断各Topic是否活跃。如果存在不活跃的Topic,请先记录Topic的名称,然后参考下文删除不活跃的Topic。

删除不活跃的Topic

对于判断为不活跃的Topic,您可以参考下列步骤进行删除,以减少资源占用量:

警告

  • 请人为判断是否需要删除不活跃的Topic。
  • 切勿调用接口自动化删除Topic,避免因为程序缺陷,对业务造成难以挽回的损失。
  1. 登录消息队列Kafka版控制台
  2. 在顶部菜单栏,选择地域。
  3. 在左侧导航栏,单击实例管理,单击需要查询的Kafka实例名称。
  4. 在实例详情页面,单击左侧导航栏中的Topic管理
  5. Topic管理页面,找到目标Topic,在其操作列中单击更多按钮,选择删除
  6. 在弹出的确认提示框中,单击确认
    警告:请务必确认无误后,再删除Topic。

相关文档

适用于

  • 消息队列Kafka版