apache-pulsar - 从 apache pulsar 主题中检索所有过去的消息

Question

我认为一个简单的例子可以更好地描述我的问题。

例如，假设有一个名为“A”的主题，我已经生成了 100 条消息 (message1...message100)。我已经使用独占类型的订阅“A_1”使用并确认了最多消息 50。由于某种原因，我的应用程序关闭了，因此在重新启动应用程序时，我需要再次读取消息 1。这可以实现吗？我在想可以创建一个新的订阅(“A_2”)并再次开始阅读消息，但我不确定“A_2”是否会从 message1 或 message51 开始阅读......任何指示或提示都会很棒!

提前致谢

Answer 1

是的，这可以实现，所需要的只是创建一个新的订阅，例如“A_2”，并使用 subscriptionInitialPosition 参数指定您要从最早的可用消息开始消费消息，如下所示:

return getClient().newConsumer()
        .topic(topic)
        .subscriptionName("A_2") 
        .subscriptionType(SubscriptionType.Exclusive)
        .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
        .subscribe();

这假定消息未因消息保留政策而被删除。