Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

How storm topology with multiple bolts processes messages

How storm topology with multiple bolts processes messages

New Contributor

I have a storm topology as

kafkaspout -> bolt1 -> bolt2 -> bolt3 .

bolt1 consumes data from kafka topic and did some validation check . If validation successfull send it to bolt2 for further processing . If invalid it simply drops and send the acknowledgement .

I want to understand once bolt1 sends message to bolt2 , will it wait for that message to be processed by bolt2 and bolt3 before consuming next message from spout ?

For e.g say Message#1 is consumed by bolt1 and after validation, sends it to bolt 2 . Will it immediately consumes and process the Message#2 while bolt2 and bolt3 are still processing Message#1 ?

1 REPLY 1
Highlighted

Re: How storm topology with multiple bolts processes messages

Rising Star

@Pankaj Goel

Hi,

Please refer section 'Bolts' of https://storm.apache.org/releases/1.2.2/Concepts.html and let me know if you have any question.

Thanks!

Don't have an account?
Coming from Hortonworks? Activate your account here