无论是实时处理还是离线处理，都会遇到一个不可避免的问题是，失败任务如何重做？Storm提供了一个ack机制。首先来...[作者空间]
原文地址查看本文原址 传统法式采用提交jar包的方式运行topology，一旦我们需要改变拓扑里头的相应配置，我们...[作者空间]
发表于个人博客，原文发表地址。JStorm虽然用Java语言重新实现了storm，但是对于storm的extern...[作者空间]
主要内容：解决部署运行遇到问题 Q1 为什么storm 部署的任务没有日志 也就是说没有采集任何数据 A: A:s...[作者空间]
问题描述：网页中登陆storm 8080端口 发现supervisor的数目与自己已经启动的supervisor个...[作者空间]
KafkaSpout 1.poutConfig继承KafkaConfig，可以通过SpoutConfig设置kaf...[作者空间]
前言： 因为前面讲个那3个demo都是local topology运行，所以对storm集群状态下的工作情况没有介...[作者空间]
背景： 我们知道在java中可以有最少3钟方式来实现定时任务：1、普通thread(里面使用while循环以及sl...[作者空间]
简介： Trident 是 Storm 的一种高度抽象的实时计算模型，它可以将高吞吐量（每秒百万级）数据输入、有状...[作者空间]
简介: Storm是一个分布式的，可靠的，容错的数据流处理系统。它会把工作任务委托给不同类型的组件，每个组件负责处...[作者空间]
