如何实现“消费者只获取对象的最新状态“(类似于 mqtt)?

  • 可设置 consumer.readCompacted(true);
  • 可参考 pulsar 文档