操作场景
Topic 的订阅关系展示了当前所有消费者的订阅状态,包括消费者列表、在线状态及消息消费情况。通过查看这些信息,您可以确认消息是否被正常消费、及时发现无消费者订阅的异常 Topic,并评估业务变更的影响范围。
前提条件
需要提前创建好对应的命名空间和 Topic。
根据 TDMQ Pulsar 版提供的 SDK 创建好消息的生产者和消费者并正常运行。
操作步骤
查看订阅详情
1. 登录 TDMQ Pulsar 版控制台,在左侧导航栏中单击 Topic 管理。
2. 在 Topic 管理列表页中,找到需要查看的 Topic,单击操作列的查看订阅/消费者,进入订阅列表。
3. 在订阅列表中,一级列表可以看到订阅了当前 Topic 的所有订阅,二级展开后可以看到每个订阅的消费连接实例以及每个分片的消费进度。

4. 您也可通过预估消费时长,来判断当前 Topic 中积压的消息完全消费完毕所需的预计时间。
说明:
预估消费时长指在当前生产与消费速率下,下游消费者将当前 Topic 中积压的消息全部消费完毕(即清空堆积)所需的预计时间。系统默认采用最近 5 分钟的平均流量速率进行估算,计算公式如下:
预估消费时长 = 当前消息堆积量 /(近 5 分钟平均消费速率 − 近 5 分钟平均生产速率)
当近 5 分钟内平均消费速率小于等于生产速率(即堆积无法被消化),或消费速率为 0 时,按上述公式计算结果为 ∞(无穷大),表示当前速率下堆积无法消费完毕。出现该情况时,建议先观察一段时间;若堆积长时间未下降,请排查业务消费逻辑或提交工单联系我们协助处理。
设置 offset
1. 在订阅列表中,单击操作列的 offset设置,按时间维度手动设定每个订阅的消费位移 offset(即指定该订阅下的消费者从哪个时间点开始消费消息)。
2. 单击提交,完成设置。


重建重试/死信队列
由于用户可以手动删除 Topic,所以当用户删除了重试/死信队列的 Topic 后,如果希望重新让系统生成这两种队列,可以通过订阅中的重建重试/死信队列操作来进行重建。
为了兼容使用旧版本SDK的用户(旧版本SDK重试和死信SDK的命名规则为小写后缀),提供两种后缀规则。新用户建议使用 Pulsar 社区版 SDK(大写后缀),无需调整本选项

删除订阅
1. 在订阅列表中,找到需要删除的订阅,单击操作列的更多 > 删除,或者勾选多个订阅之后单击订阅列表顶部的删除。
2. 在弹出的提示框中,单击删除,提交完成。
说明:
在某个 Topic 下删除了某个订阅之后,若该订阅还订阅了其他 Topic(包括系统创建的重试/死信队列),则这个订阅还会在其他 Topic 下存在,并不会被真正删除。
开启强制删除后,即使订阅仍有消费者连接,也可以强制删除。
