0

我在 Hazelcast Jet 5.0（或 4.x）文档中找不到这个，所以我希望有人可以在这里回答这个问题 - 可以将可靠的主题用作幂等接收器，例如对来自两个相同不可靠来源的重复事件进行去重（如网络套接字）。或者我应该按照https://hazelcast.com/blog/stream-deduplication-with-hazelcast-jet/的建议使用明确的事件重复数据删除？或者有没有更好的方法来处理像 websockets 这样的不可靠来源（我的意思是我不想错过通过 websocket 摄取的事件，并且单个 websocket 实例可能失败的可能性非零）？

4

2 回答 2

0

任何队列通常都不能用于重复数据删除。如果您两次提供相同的项目，则无法忽略此类调用，因为它必须存储整个历史记录中的标识符，或者您必须指定存储限制，如您链接的示例中的 TTL 属性filterStateful是用过的。

于 2021-12-27T14:29:40.380 回答
0

我最终putIfAbsent()在IMap日记中使用了 a - 我认为对于我的用例来说，这比上面链接的重复数据删除解决方案要简单得多（而且有些明显）。

于 2022-01-01T18:27:27.927 回答