加载中
Storm笔记

用了一段时间Storm后的笔记。发现可以记的东西不多,证明Storm挺简单的,你只要遵循一些简单的接口与原则,就能写出大规模实时消息处理的程序。 不断更新中,请尽量访问博客原文。 为什么用S...

2016/09/27 14:16
254
Storm集成Redis

Storm集成redis前的准备 代码 查看结果

2016/01/20 14:03
2K
Storm nimbus HA

nimbus ha的介绍

2016/04/11 11:13
1.2K
Storm在zookeeper上的目录结构

Storm的所有的状态信息都保存在Zookeeper里面,nimbus通过在zookeeper上面写状态信息来分配任务: 使得nimbus可以监控整个storm集群的状态,从而可以重启一些挂掉的task。 ZooKeeper使得整个s...

Storm 1.0.0 正式发布

新版本的新特性

2016/04/15 17:45
1.2K
flume kafka storm常用命令

flume kafka storm 常用命令

2015/10/10 16:06
536
Storm相关概念与配置项

记录Storm学习过程中的知识点

2015/07/10 17:00
244
Storm的参数构造问题记录

Storm正常的参数构造应该放在prepare方法中,但是如果你放在了bolt的构造函数的中,则会出现问题,参数得不到正常的初始化,原因如下: Bolt是Storm中的基础运行单位,当接收到一条数据时可以...

2016/09/27 14:55
190
storm定时器timer源码分析-timer.clj

storm定时器与java.util.Timer定时器比较相似。java.util.Timer定时器实际上是个线程,定时调度所拥有的TimerTasks;storm定时器也有一个线程负责调度所拥有的"定时任务"。storm定时器的"定时...

Storm 1.0.1 sliding window结合kafka spout [ 错误记录 ]

出现kafka的消息重播现象

2016/08/05 13:50
164
storm shell命令源码分析-shell_submission.clj

当我们在shell里执行storm shell命令是会调用shell_submission.clj里的main函数。shell_submission.clj如下: shell_submission.clj ;; ns函数声明一个命名空间“backtype.storm.command.sh...

2016/04/13 17:43
103
Kafka知识点汇总

欲有序先无序

2016/01/10 16:07
526
Kafka剖析(一):Kafka背景及架构介绍

背景介绍 Kafka创建背景 Kafka是一个消息系统,原本开发自LinkedIn,用作LinkedIn的活动流(Activity Stream)和运营数据处理管道(Pipeline)的基础。现在它已被多家不同类型的公司 作为多种...

2016/01/28 12:01
167
Kafka设计解析(四):Kafka Consumer解析

High Level Consumer 很多时候,客户程序只是希望从Kafka读取数据,不太关心消息offset的处理。同时也希望提供一些语义,例如同一条消息只被某一个Consumer消费(单播)或被所有Consumer消费...

2016/01/29 13:56
167

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部