Storm Trident 状态实现 Txid 比较

Question

我正在构建一个风暴三叉戟拓扑，并且在某些时候我正在使用 partitionPersist 阶段将数据存储到 solr。我已经实现了 State 类并编写了一些逻辑来使用 StateUpdater 更新 solr。我是否在任何阶段都必须跟踪事务 id (txid) 以确保我不会将重复项存储到 solr 中，或者 trident 会为我处理这个问题？

Answer 1

是的，您必须自己跟踪 txid。