我使用的是storm，一个拓扑有一个bolt“a”，它在数据库中插入记录并发送到另一个bolt“b”。如果一个元组bolt“b”执行失败，当bolt“a”执行时，如何回滚对数据库产生影响的元组？有人能帮我吗？谢谢
2admgd591#
要了解storm是如何处理事务的，请查看它们的事务拓扑文档。它写得很好，应该给你一个很好的概念在同一方面。现在不用使用普通的storm来管理事务了，您可以使用trident，trident是在storm之上构建的一个顶级抽象，它允许更好地实现事务功能。文件很好，详细描述了方法。另外，请看这里，了解storm如何保证消息得到充分处理。
1条答案
按热度按时间2admgd591#
要了解storm是如何处理事务的，请查看它们的事务拓扑文档。它写得很好，应该给你一个很好的概念在同一方面。
现在不用使用普通的storm来管理事务了，您可以使用trident，trident是在storm之上构建的一个顶级抽象，它允许更好地实现事务功能。文件很好，详细描述了方法。
另外，请看这里，了解storm如何保证消息得到充分处理。