storm保证数据可靠性如何代码实现?

前提是已经知道了apache-storm的3种数据处理级别:
1.至多一次
2.至少一次
3.恰好一次

storm默认是使用第一种处理级别。

我希望做的是第三种(因为对所需数据处理的要求比较高)

官网给的教程看的我是云里雾里
美团这篇文章讲了大概思路 但是没有具体怎么写

我想知道第三种处理级别的大致原理以及如何代码实现(越具体越好)

谢过大佬

阅读 703
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题