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();

这假定由于邮件保留策略而未删除邮件。

Answer 2

在 Pulsar 中保持消息的接收和确认是分开的，这意味着可以编写您的应用程序，以便它仅在不再需要消息时才确认消息。

当您确定应用程序不再需要它时，考虑只确认消息可能很有用。

否则，@david-kjerrumgaard 所说的。