Is your message source thread safe? It is possible for four spout threads to read the same message from the same source if the source does not guarantee uniqueness across multiple clients. On Aug 27, 2015 9:59 AM, "Ganesh Chandrasekaran" < [email protected]> wrote:
> Hi all, > > > > I am noticing a strange behavior in one of my topology. The configuration > is as follows: > > - Using RabbitMQ for publishing/consuming messages > > - Single topology with 2 workers running 4 threads each (Using > multilang protocol) > > > > I log messages every time a message gets published to rabbit queue so I > queued a message just once. But I noticed 4 processes trying to process the > same message within a gap of 60 milli seconds. > > > > I know only during some kind of failures Storm can replay messages based > on certain configurations. I would expect to have some time gap in those > scenario (like message timeouts interval or something) But is the above > scenario possible at all that multiple threads process same message within > 60 millisec? If yes, how? > > > > Thanks, > > Ganesh >
