解决方法cat /opt/storm-0.8.2/conf/storm.yaml中找到storm.local.dir设定的目录,备份supervisor和workers两个文件夹,#nohup supervise /service/storm/ &重启错误如下2014-06-17 12:27:05,...
                            
                            
                                分类:
其他好文   时间:
2014-08-12 16:38:54   
                                阅读次数:
198
                             
                         
                    
                        
                            
                            
                                简介kafka网站上提供了C语言的客户端librdkafka,地址在这。librdkafka是使用C语言根据apache kafka 协议实现的客户端。另外这个客户端还有简单的c++接口。客户端作者对这个客户端比较上心,经常会修改bug并提交新功能。librdkafka的基本原理和我之前博客说的ja...
                            
                            
                                分类:
其他好文   时间:
2014-08-12 00:25:33   
                                阅读次数:
766
                             
                         
                    
                        
                            
                            
                                http://www.codeproject.com/Articles/42799/Storm-the-world-s-best-IDE-framework-for-NETStorm - the world's best IDE framework for .NETgone000,4 Feb 201...
                            
                            
                                分类:
Web程序   时间:
2014-08-11 20:35:12   
                                阅读次数:
511
                             
                         
                    
                        
                            
                            
                                Apache Kafka是一个分布式消息发布订阅系统。它最初由LinkedIn公司基于独特的设计实现为一个分布式的提交日志系统( a distributed commit log),,之后成为Apache项目的一部分。Kafka系统快速、可扩展并且可持久化。它的分区特性,可复制和可容错都是其不错的特性。
Apache Kafka与传统消息系统相比,有以下不同:
    它被设计为一个分布式系统,易于向外扩展;
    它同时为发布和订阅提供高吞吐量;
    它支持多订阅者,当失败时能自动平衡消费者;
...
                            
                            
                                分类:
其他好文   时间:
2014-08-11 15:08:32   
                                阅读次数:
389
                             
                         
                    
                        
                            
                            
                                目录: 一、什么是kafka? 二、kafka的官方网站在哪里? 三、在哪里下载?需要哪些组件的支持? 四、如何安装? 五、FAQ 六、扩展阅读 一、什么是kafka? kafka是LinkedIn开发并开源的一个分布式MQ系统,现在是Apache的一个孵化项目。在它的主页描述kaf...
                            
                            
                                分类:
编程语言   时间:
2014-08-11 14:24:32   
                                阅读次数:
496
                             
                         
                    
                        
                            
                            
                                SingleJoinExample示例说明了storm中流聚合的应用,将具有相同tuple属性的数据流整合成一个新的数据流。来看一下Topology。先定义两个数据源genderSpout和ageSpout,Fields分别为("id", "gender")、("id"...
                            
                            
                                分类:
其他好文   时间:
2014-08-11 12:16:12   
                                阅读次数:
253
                             
                         
                    
                        
                            
                            
                                官方提供的storm starter示例中,有很多应用的例子,对storm的应用场景理解很有帮助。本文结合源码来进行功能分解,记录一下,作为记忆索引吧。 ? ? 先来看一个比较简单的示例:WordCountTopology,原版代...
                            
                            
                                分类:
其他好文   时间:
2014-08-11 10:23:22   
                                阅读次数:
201