java - 风暴拓扑事务和数据库事务

Question

我正在使用风暴，A 拓扑有一个螺栓“A”，它在数据库中插入记录并发射到另一个螺栓“B”。如果元组bolt“B”执行失败，当bolt“A”执行时如何回滚对数据库影响的元组？任何人都可以帮助我吗？谢谢

Answer 1

要了解 Storm 如何处理事务，请查看他们的事务拓扑文档。它写得很好，应该给你一个很好的概念。

现在，您可以使用trident ，而不是使用普通的 Storm 来管理事务，它是建立在 Storm 之上的顶级抽象，并允许更好地处理事务功能。这些文档很好，并详细描述了该方法。

另请参阅此处以了解风暴如何保证消息得到充分处理。