I don't understand what's mean that should use the trident if the message process must only once Can I process message only once using ack() and fail() on BaseRichSpout? If I don't need the trident's functions(eg. groupping, jonning..), Can I use the BaseRich?
I don't understand what's mean that should use trident if the message process must only once
56 views Asked by 이진희 At
1
There are 1 answers
Related Questions in APACHE-STORM
- ERROR: org.apache.hadoop.fs.UnsupportedFileSystemException: No FileSystem for scheme "maprfs"
- Use rack aware policy for kafka in apache storm
- Apache storm + Kafka Spout
- Getting classCastException when upgrade from strom/zookeepr 2.5/3.8.0 to 2.6/3.9.1
- Does SGX or Gramine support mmap files?
- Apache Storm: Get Blob download exception in Nimbus log
- Apache Storm: can't receive tuples from multiple bolts
- How to make apache storm as FIPS (Federal Information Processing Standard ) compliant
- one bolt recive from 2 others in streamparse python
- How to deploy a topology on Apache Storm Nimbus deployed on AWS ECS
- How to store custom metatags in elasticsearch index from a website using stormcrawler
- conf/storm.yaml is not populated with values coming from config map
- How to process late tuples from BaseWindowedBolt?
- Unable to Start this Storm Project
- Handing skewed processing time of events in a streaming application
Related Questions in TRIDENT
- Storm Trident group by selected fields before windowing
- Could I use Trident library to generate the absorption spectrum of atoms/molecules like carbon
- Why does the locaton of my animated circles flicker?
- rancher trident storage integration w/ rancherOS 1.55
- how to groupby tuples within a window in Storm trident?
- Apache Storm: Supervisor kills and restarts worker process
- Why does Trident not call ack() or fail() in this minimal example?
- Prometheus and nfs storage
- Do we need to remove duplicate by ourselves on at least once delivery case?
- How to fix error 'Component: [x] subscribes from non-existent component [y]' in Apache Storm Trident topology
- Reading data form Elasticsearch into Flink aggregation?
- How can I return a tuple with multiple fields from Combiner/Reducer/Aggregator function?
- Find the word having the maximum count using a Trident topology
- KafkaTridentSpoutOpaque Repeated consumption the last message
- storing intermediate data in storm topology
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Storm supports "at least once" process, as the failed message will be handled again from the beginning, which will cause some repetition.
Trident is one way to support "exactly once" process.
So if you have to handle messages only once in storm ,you have to use trident.