java - 主题订阅 - 至少处理一次

Question

我有一个基于主题的事件发布者，我想在订阅时重播之前的 20,000 个事件。发布者不支持此功能，我不想运行其他服务，如 Kafka。

我有一个将订阅主题并将事件发布到ReliableTopicHazelcast 提供的应用程序。如果我理解正确，我可以配置后备环形缓冲区以提供我所追求的功能。

此应用程序有多个实例以实现冗余。如何防止所有实例都订阅事件发布者并发布到ReliableTopic; 以nx 事件结束（实例数ReliableTopic在哪里）？n

当没有故障（eventid mod 实例编号）时，这很容易处理......它是我坚持的故障场景 - 实例x死亡时会发生什么。

我正在寻找“至少一次”（希望大多数时候一次）样式处理 - 我的应用程序可以在技术上支持重复。

标签： javamessaginghazelcast