Pulsar中是否有方法清理未绑定消费者的旧持久化订阅？

自动清理无关联消费者的持久化订阅 #

Pulsar原生支持订阅自动过期能力，可直接通过配置实现只清理无消费者绑定、且超过指定时长未活跃的订阅，完全不会影响其他处于正常闲置状态的订阅：

• 命名空间级别配置（更推荐，粒度灵活不影响其他业务）：
  用pulsar-admin命令可直接设置，示例配置为超过24小时无活跃的订阅自动删除：

  pulsar-admin namespaces set-subscription-expiration-time <租户名>/<命名空间名> --expiration-time 86400
  

  配置项单位为秒，设置为0即可关闭该命名空间的订阅自动过期逻辑。
• 全局broker配置（适合全集群统一规则的场景）：
  在broker.conf中添加如下配置后重启broker生效，示例配置同样为24小时过期：

  subscriptionExpirationTimeMinutes=1440
  

  该配置单位为分钟，设置为0即可关闭全局订阅自动过期逻辑。

上述配置只会触发清理无任何活跃消费者连接、且超过配置时长没有任何消费/消息确认操作的持久化订阅，正在使用的、或是闲置未到过期阈值的订阅都不会被误删。

手动清理残留订阅 #

如果需要立即清理已经确认无用的残留订阅，不需要等过期阈值触发，可直接通过命令行定向删除：

• 先查询指定主题下的所有订阅，确认待删除的订阅名称：

  pulsar-admin topics subscriptions <主题完整路径>
  

• 确认后删除指定订阅，不会影响同主题下的其他订阅：

  pulsar-admin topics unsubscribe -s <订阅名称> <主题完整路径>
  

如果需要批量清理大量残留订阅，可直接调用Pulsar Admin API遍历主题、过滤无消费者的订阅后批量执行删除即可。

从根源避免Spark作业残留订阅 #

针对你提到的Spark作业运行后残留订阅的场景，可在Spark作业的Pulsar消费者逻辑中添加退出钩子，作业正常结束时主动调用unsubscribe方法销毁订阅即可，注意仅在确认该订阅后续不会复用时开启该逻辑。

内容的提问来源于stack exchange，提问作者kellyfj