CODEWITHSUNDEEP
javareal-timeapache-storm
user1221244
user1221244

Reputation: 299

Storm topology transaction and Database transaction

I am using storm, A topology has a bolt "A" which insert record in database and emit to another bolt "B". If a tuple bolt "B" execute failed, How to rollback the tuple effected on database when bolt "A" executed? Anyone can help me? THX

Upvotes: 4

Views: 1317

Answers (1)

user2720864
user2720864

Reputation: 8171

To understand how storm deals with transaction take a look at their Transactional topology documentation . Its nicely written and should give you a good concept on the same.

Now instead of managing the transaction using normal storm you can go for trident which a top level abstraction build on top of storm and allows a better approach towards transactional functionalities. The documents are nice and describe the approach in details.

Also look here to know how storm guarantees messages to be processed fully.

Upvotes: 1

Related Questions