Apache Pulsar中Replay/Reset消息问题：能否重放保留期内旧消息

Apache Pulsar 完全支持重放处于消息保留期内的旧消息，该特性属于官方原生支持的核心能力，你可以通过内置API或管理工具很方便地实现按时间维度的消息重放需求。

前置依赖说明 #

你需要提前确认待重放消息所属的Topic/Namespace已配置符合要求的消息保留策略，且目标消息尚未超出设置的保留时长、保留大小阈值。超出保留期的消息会被Pulsar自动清理，无法执行重放操作。

基于时间戳的消息重放实现 #

1. 消费者代码侧实现 #

所有语言的Pulsar官方SDK都提供了按时间戳定位消费位置的方法，调用后消费者会自动跳转至大于等于目标时间戳的第一条消息处，后续消费就从该位置开始：

• Java SDK：调用consumer.seek(long timestamp)，参数为毫秒级Unix时间戳
  示例：

  // 重放到72小时前的消息位置
  long targetTimestamp = System.currentTimeMillis() - 3 * 24 * 3600 * 1000;
  consumer.seek(targetTimestamp);
  

• Go SDK：调用consumer.SeekByTime(time.Time time)
• Python SDK：调用consumer.seek_by_timestamp(int timestamp)

2. 命令行工具实现 #

你可以直接用pulsar-admin命令对指定订阅执行重放操作，不需要修改业务代码：

./pulsar-admin topics seek <完整Topic名称> -s <订阅名称> -m <毫秒级Unix时间戳>

指定时间周期的消息重放实现 #

如果需要重放某一段固定时间区间内的消息，可以按如下流程操作：

• 调用上述按时间戳定位的方法，先将消费位置跳转到区间的起始时间点
• 启动消费者开始拉取消息，每次消费时校验消息自带的发布时间Message.getPublishTime()
• 当消费到的消息发布时间超出你设定的区间结束时间时，主动停止消费即可

注意事项 #

• 消息重放操作仅作用于你指定的订阅，不会影响同Topic下其他订阅的消费进度
• 若你开启了消息去重特性，重放的消息会被正常投递给消费者，不会被判定为重复消息丢弃
• 若目标消息已归档到冷存储，只要配置了正常的冷存储读取权限，重放逻辑和热存储消息完全一致，不需要额外适配

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