我正在构建一个storm trident拓扑,并在某个时候使用partitionpersist阶段将数据存储到solr中。我已经实现了state类,并编写了一些逻辑来使用stateupdater更新solr。我是否在任何阶段都必须跟踪事务id(txid)以确保不会将副本存储到solr中,或者trident会为我处理这个问题?
wqlqzqxt1#
是的,你必须自己跟踪血栓素。
1条答案
按热度按时间wqlqzqxt1#
是的,你必须自己跟踪血栓素。