0
我正在构建风暴三叉戟拓扑,并且在某些时候我使用partitionPersist阶段将数据存储到solr中。我已经实现了State类并编写了一些逻辑来使用StateUpdater更新solr。我是否在任何阶段都必须跟踪交易ID(txid)以确保我不会将重复项存储到solr中,否则三叉戟会为我处理此问题吗?风暴三叉戟状态实施Txid比较
我正在构建风暴三叉戟拓扑,并且在某些时候我使用partitionPersist阶段将数据存储到solr中。我已经实现了State类并编写了一些逻辑来使用StateUpdater更新solr。我是否在任何阶段都必须跟踪交易ID(txid)以确保我不会将重复项存储到solr中,否则三叉戟会为我处理此问题吗?风暴三叉戟状态实施Txid比较
是的,你必须自己跟踪txid。