Trade Topology and Database Transaction

Question

I use the storm. In the topology, there is a bolt “A” that inserts a record into the database and emits another bolt “B”. If set B error is unsuccessful, how to roll back a tuple executed in the database when executing bolt A? Can anybody help me? thanks

Answer 1

To understand how storms make transactions, see their Transactional Topology Documentation . Its well written and should give you a good idea of ​​the same.

Now instead of managing a transaction using a normal storm, you can go trident , where the top-level abstraction is built on top of the storm and allows a better approach to transactional functions. The docs are good and detail the approach.

Also look here to see how storm safety messages will be handled completely.