检索结果-南通市图书馆

作者：李存正安徽理工大学

学位级别：硕士

在数据爆炸式增长的今天,日志数据具有巨大的价值,它可以帮助系统快速定位故障,及时恢复系统运行;分析客户行为,来达到业绩快速增长等。许多中小企业和机构都不能很好的利用自己的日志数据,这些企业和机构不能很好利用这些日志数据的原... 详细信息

在数据爆炸式增长的今天,日志数据具有巨大的价值,它可以帮助系统快速定位故障,及时恢复系统运行;分析客户行为,来达到业绩快速增长等。许多中小企业和机构都不能很好的利用自己的日志数据,这些企业和机构不能很好利用这些日志数据的原因有如下几点:①中小企业机构盈利有限,单独开发复杂的日志分析管理系统成本太大,得不偿失。②使用开源的通用日志分析系统,几乎没有开发成本,但是很难精确的与公司业务相结合,使之成为鸡肋。ELK架构是目前主流的日志大数据分析通用解决方案之一,ELK拥有比Spark更高的实时性,集成和部署比Spark简单方便,而且几乎可以在任何系统中进行集成。但是正是由于这种的通用性,导致了它只能适用于一些简单的场景,无法像Spark一样精确针对每个应用系统进行复杂业务分析扩展。为了能同时兼顾降低前期日志收集和清洗的开发成本、分析的高实时性和可扩展性。本文将ELK-Stack和Spark相结合,形成日志采集、日志处理、日志分析和结果展示四个模块来构建一套可扩展、高实时性且具有良好稳定性的征信日志挖掘系统,用来分析系统、业务、用户三个层次的日志。在前期只需利用ELK Stack的收集和过滤插件简单的配置集群和定义过滤规则,就能实现日志的收集和处理,这样作比全栈Hadoop技术的大数据系统开发工作量减少60%以上;再利用Elasticsearch的高实时性,进行简单的数据实时分析,就能达到分析实时结果的要求;最后把过滤后的数据传输到HDFS中,利用Spark框架进行个性化编程,这样该系统就具有可以根据企业需求灵活进行自定义分析组件的优点。同时,引入kafka消息队列来解决传输过程中的数据丢失问题。本文还进一步研究了多种ELK与Spark对接的方法,分析了各种方法的优缺点,优化了 ELK与Spark对接方式,使其在处理效率上得到了很大的提高。图22 表3 参数50

关键词： ELK Spark 日志挖掘征信日志 kafka 可扩展

分布式战术互联网仿真系统关键技术研究与实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

分布式战术互联网仿真系统关键技术研究与实现

作者：李朔北京交通大学

学位级别：硕士

现代战术互联网是国防信息化建设的重要组成部分,具有规模大、技术类型多样、结构复杂的特点,采用传统的单机网络仿真技术难以满足研究需求,而分布式仿真技术因其强大的灵活性、可扩展性和互操作性已经成为了战术互联网领域最为主要的... 详细信息

现代战术互联网是国防信息化建设的重要组成部分,具有规模大、技术类型多样、结构复杂的特点,采用传统的单机网络仿真技术难以满足研究需求,而分布式仿真技术因其强大的灵活性、可扩展性和互操作性已经成为了战术互联网领域最为主要的研究手段。近年来国内战术互联网仿真领域的研究多集中在仿真模型设计层面。在仿真系统研发方面,大多数工作都是针对单功能仿真应用的开发实现,难以满足军用领域对于综合战术互联网仿真系统的需求。本文主要研究分布式战术互联网仿真相关的理论和技术,以构建综合性分布式战术互联网仿真系统为目标,主要研究内容和开发工作如下:首先,基于HLA技术设计了分布式战术互联网仿真系统。基于系统仿真职能,将仿真联邦划分为网络规划、战术对抗想定、战术通信网络、终端模拟和效能评估五种联邦成员。重点研究联邦成员间的交互关系,对仿真联邦交互流程进行了规划设计,将流程划分为“网络部署→节点同步→网络仿真→效能评估”四个阶段,对交互逻辑较为复杂的网络部署和节点同步阶段进行了交互算法设计。设计了联邦成员的时间管理策略,明确了各成员仿真执行的时序关系。其次,研究HLA分布式仿真系统中数据传输效率低下的问题,引入kafka消息中间件,设计了HLA-kafka双总线分布式仿真系统架构。保持HLA在仿真系统中的主导地位,由kafka来分担RTI的数据传输压力,利用kafka高吞吐量、低延迟的特性提高了分布式仿真系统的数据传输效率。最后,基于Pitch p RTI1516运行支撑环境对分布式战术互联网仿真系统进行了实现。以旅级战术网络仿真任务为例,对仿真系统的完整运行流程进行了展示。针对HLA-kafka双总线仿真系统和HLA仿真系统设计对比实验,以交互类信息的传输时延和吞吐量为指标对仿真系统的数据传输效率进行测试。结果表明HLA-kafka双总线仿真系统在交互类数据传输方面的性能要远优于HLA仿真系统。综上所述,本文基于HLA技术设计实现了分布式战术互联网仿真系统,建立了从“网络规划部署”到“战术想定仿真”、“战术通信网络仿真”、“终端模拟显示”最终进行“效能评估”的完整仿真链条,为战术互联网系统建设提供了一套较为完整、先进的仿真联试环境,对于我军战术互联网系统的规划、设计、研制和应用具有一定的参考意义。同时,针对HLA仿真系统中数据传输效率低下的问题,对原有系统结构进行改进,设计了HLA-kafka双总线仿真系统架构,利用kafka高吞吐量、低延迟的特性提高了仿真系统的数据传输效率。

关键词：战术互联网分布式仿真系统 HLA kafka 双总线数据交互

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

支持工作流的实时大数据处理平台设计与实现

支持工作流的实时大数据处理平台设计与实现

作者：贾韶光北京邮电大学

学位级别：硕士

近几年来,大数据已经渗透到人类生活的方方面面。随着移动互联网和物联网的发展,我国大数据产业的发展也进入爆发期,大数据已经上升为国家战略。大数据处理系统也有了更多样的业务需求,导致支撑大数据处理的各项技术逐步走向成熟。把不... 详细信息

近几年来,大数据已经渗透到人类生活的方方面面。随着移动互联网和物联网的发展,我国大数据产业的发展也进入爆发期,大数据已经上升为国家战略。大数据处理系统也有了更多样的业务需求,导致支撑大数据处理的各项技术逐步走向成熟。把不同的技术融合成一个大型的大数据处理系统,这样的系统架构在实际生产中得到了广泛应用。但是其学习成本和维护成本非常高,同一个开发者很难维护和扩展这么多复杂技术融合而成的系统。针对以上问题,结合课题组的项目,本文设计并实现了支持工作流的实时大数据处理系统。本文首先研究了mxGraph框架的组织结构和底层实现原理,将其与Web技术结合,搭建了支持工作流的大数据管理平台。在此基础上,总结了大数据处理关键技术Flume、kafka的相关配置和Spark Streaming的工作原理,部署了大数据处理系统。最后将可视化信息管理平台与大数据处理系统结合在一起,实现了支持工作流的实时大数据处理系统。系统设计的核心功能体现在可以通过支持工作流的大数据管理平台实现大数据处理的可视化配置。将大数据处理系统的配置信息统一提取出来,交由大数据管理平台统一配置管理。大数据管理平台使用XML格式的数据传递配置信息,配置信息通过校验后,可以在数据库中进行读写,也可以写入大数据处理系统的配置文件。通过可视化配置,将工作流程组织成符合逻辑和规则的大数据处理流程,控制大数据处理系统在计算机中以恰当的方式实施大数据处理。开发者只需要学习大数据处理技术的原理,掌握大数据处理技术平台的配置参数和简单的数据流向,就可以轻松实现实时数据处理业务。本文解决了开发系统难度大和维护成本高的问题,同时系统可扩展性好,而且针对每个大数据处理系统的每个步骤,都可以有实时反馈信息。

关键词：大数据处理 Flume kafka mxGraph 工作流

基于Dubbo的汽车养护预约系统的设计与实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

基于Dubbo的汽车养护预约系统的设计与实现

作者：赵燕西安电子科技大学

学位级别：硕士

随着中国社会经济的快速发展,庞大的人口基数带动汽车保有量迅猛增加,目前我国仍然是全球最大的单一汽车市场。中国汽车产业的迅猛发展,体现出人们生活水平不断提高,中国汽车后市场的形成也是在汽车产业不断发展中诞生的。随着互联网的... 详细信息

随着中国社会经济的快速发展,庞大的人口基数带动汽车保有量迅猛增加,目前我国仍然是全球最大的单一汽车市场。中国汽车产业的迅猛发展,体现出人们生活水平不断提高,中国汽车后市场的形成也是在汽车产业不断发展中诞生的。随着互联网的发展,互联网产业已经应用于人们生活的方方面面,把庞大体系汽车后市场业务与互联网进行融合,推动汽车后市场互联网化。当前,门店维修的服务模式已不能适应市场需求,便捷高效的汽车维修保养预约对于提升人民的生活质量,加速社会发展起到了积极的作用。因此,本文将设计和开发基于移动互联网的在线预约服务软件,为用户提供在线预约的服务,推动目前汽车后市场的发展。本文设计的汽车养护预约系统采用微服务的架构进行设计与开发,利用面向服务的设计思想,实现用户在线预约软件和后端管理员管理平台的开发。首先,结合目前传统汽车后市场,对本文的研究意义和背景进行分析,对相关系统的国内外发展现状进行研究,推出本文设计的基于Dubbo的汽车养护预约平台,并提出本文的研究内容及组织结构。其次,对实现基于Dubbo的汽车养护预约系统中用到的技术和研究方法进行介绍。接着,对汽车养护预约系统的用户端和管理平台进行系统梳理,根据实际业务操作汇总出实际需求,并结合相应的用例图和活动图对系统的主要功能性需求进行分析,对系统的非功能需求进行阐述。然后,对汽车养护预约系统进行详细的设计与实现,详细设计是从总体架构设计、系统微服务设计、数据库设计、功能模块设计与实现这几个方面来描述的。依据需求分析对系统微服务进行设计以及对功能模块进行分解,然后对每个微服务的数据库的物理结构和逻辑结构进行设计。在具体的实现框架上,系统采用更加轻量级的Spring Boot、Mybatis框架模型进行开发,以Dubbo分布式架构为基础,使用了kafka异步消息队列和存储引擎Elasticsearch等技术完成相应功能的实现。每个模块的实现使用类图和时序图进行详细介绍。最后,利用黑盒测试方法完成了对用户端和后端管理平台功能模块的测试,利用Load Runner专业测试软件对系统性能进行测试及分析,解决系统中存在的缺陷及漏洞,至此完成基于Dubbo的汽车养护预约系统的设计与实现。汽车养护预约系统的开发具有重要的意义,搭建了客户与自营连锁养车店之间的桥梁,通过线上预约和实体店线下开展实际业务的模式,使客户对所需的相关零件产品和服务的购买更加便捷和清晰,让客户拥有多样化的选择,增强客户全流程的消费质量,将车主用户的维修保养流程完全数字化、可视化。

关键词：汽车后市场预约微服务 Dubbo Spring Boot kafka

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

办公楼公共空间预定管理系统的设计与实现

办公楼公共空间预定管理系统的设计与实现

作者：陈煜哲南京大学

学位级别：硕士

在智能楼宇理念影响不断扩大的背景下,人们对智能楼宇的需求由高效趋向于高效兼具舒适,社会对智能楼宇的要求趋向于智能兼具绿色,但是配备的软件系统目前还比较欠缺。本文致力于将办公区域繁琐的空间管理变得轻松快捷,设计开发的办公楼... 详细信息

在智能楼宇理念影响不断扩大的背景下,人们对智能楼宇的需求由高效趋向于高效兼具舒适,社会对智能楼宇的要求趋向于智能兼具绿色,但是配备的软件系统目前还比较欠缺。本文致力于将办公区域繁琐的空间管理变得轻松快捷,设计开发的办公楼公共空间预定管理系统用于预订展厅、培训室、报告厅、洽谈室、面试间、员工活动室、小型会议室、中型会议室、大型会议室等房间,引入邮箱属性,通过邮箱进行预约和反馈,结合了Web端日历系统、Pad端预约屏和微信小程序实现多平台管理,提高了可用性。本系统还提供签到、在Pad端广播重要通知、空间自动释放等功能。系统提供数据看板方便实时了解各楼层空间的使用状态,同时,从不同的维度进行数据分析,例如,对空间的健康程度、使用效率进行评估和建议,为空间资源的合理分配提供决策依据。本文在内容上围绕办公楼公共空间预定管理系统的研究过程进行展开,阐述了日历预约管理、空间信息管理、邮件通知管理、预约屏预约管理、权限管理和系统管理等核心模块的设计与实现。项目整体开发采用B/S架构,使用Dubbo框架处理房间主题和邮件等任务,使用kafka协助状态变更处理。前端采用Vue框架,因为它轻量、组件化的特点方便开发。Spring Boot前后端分离的结构减少了耦合,提升可移植性,方便了多平台的访问,使用关系型数据库My SQL来进行数据保存,同时借助Redis进行数据缓存,进一步加速响应速度,减轻对关系型数据库访问的压力,保证空间资源的互斥访问。目前,此套办公楼公共空间预定管理系统已在字节跳动卫星通信大厦投入使用,经使用方反馈本系统运行良好,不仅极大减轻了后勤人员的工作负担,还使员工的工作体验得到很大的提升。

关键词：空间预定 SpringBoot kafka Dubbo 多平台

基于Storm的实时营销监控与反欺诈平台设计与实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

基于Storm的实时营销监控与反欺诈平台设计与实现

作者：刘召羽东华大学

学位级别：硕士

近年来,基于互联网的营销、推广活动越来越多,收到了良好的效果。同时,针对营销推广活动的各种欺诈行为也开始大量出现,给相关企业造成了巨大损失,必须采取相应的措施有效地识别欺诈行为。传统的营销监控与反欺诈平台通常使用关系型数... 详细信息

近年来,基于互联网的营销、推广活动越来越多,收到了良好的效果。同时,针对营销推广活动的各种欺诈行为也开始大量出现,给相关企业造成了巨大损失,必须采取相应的措施有效地识别欺诈行为。传统的营销监控与反欺诈平台通常使用关系型数据库以及建模分析等技术实现对营销活动的监控及欺诈行为的识别,但是由于现在营销活动参与人数的爆炸性增长,以及用户对营销活动奖励结算实时性的要求越来越高,传统平台已经渐渐不能满足当下的需求。本文结合国泰君安证券股份公司的实际营销项目,使用kafka作为消息队列系统,使用Storm流计算引擎结合Redis缓存进行计算,并结合WebSocket与HTML5进行结果呈现,构建出了基于Storm的实时营销监控与反欺诈平台。新平台给出了分布式流数据采集、数据实时传输、流数据计算、中间结果缓存、数据实时推送以及结果呈现等功能的实现,大大提高了平台的性能及可扩展性,成功地解决了传统平台实时性差、吞吐量低等缺陷,实现了毫秒级的响应与每日数百GB的数据吞吐量。

关键词： Storm kafka Redis 流处理反欺诈

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

一种数据同步系统的设计与实现

一种数据同步系统的设计与实现

作者：曾泽堂南京大学

学位级别：硕士

在系统逐渐发展,复杂度增加之后会产生数据同步的需求。系统需要将数据同步到同构数据库做冗余备份,或者是同步到异构数据库提供其他服务。数据同步工具有许多应用场景:数据库管理员进行数据库实时备份以及数据恢复;微服务开发者为了进... 详细信息

在系统逐渐发展,复杂度增加之后会产生数据同步的需求。系统需要将数据同步到同构数据库做冗余备份,或者是同步到异构数据库提供其他服务。数据同步工具有许多应用场景:数据库管理员进行数据库实时备份以及数据恢复;微服务开发者为了进行数据自治进行数据冗余,或者为了提高查询效率从而将两张表进行Join;大数据开发平台为了进行大规模在线、离线计算而同步获取业务数据。目前虽然也有许多开源的数据同步工具,但是它们对于一些复杂的业务场景不能提供很好的支持。本文首先介绍了一些基本的一致性理论与技术。基本理论包括FLP不可能性原理(FLP impossibility),CAP定理(CAP theorem),最终一致性理论(Eventual consistency),复制状态机算法(State machine replication),至少一次语义(At least once semantic)与刚好一次语义(Exactly once semantic)理论。相关实现技术包括主从同步协议(Master Slave Replication Protocol),预写式日志(Write Ahead Log),检查点(Checkpoint),重试机制、消息顺序调度器以及幂等。为了实现同步的最终一致性,本文提出了一套设计方案:在获取数据变更方面,采用MySQL的主从同步协议,将工具伪装为MySQL的从服务器;在处理变更时,采用预写式日志、检查点、重试机制等技术,实现了数据同步的最终一致性;采用消息顺序调度器,在确保关联数据变更顺序正确的同时,提高了无关联数据变更的并发处理能力。获取数据变更的模块被设计为生产者模块,而处理数据变更的模块被设计为消费者模块。依据本文实现的数据同步工具,在兼顾性能的同时,实现了最终一致性,已经在企业中得到了应用。该工具(Syncer)由本人设计、实现,目前已在Github上开源(https://***/zzt93/syncer)。

关键词：数据同步 MySQL Binary Log MongoDB Oplog kafka Elasticsearch

基于时间序列的海量网络流量分析系统的研究与实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

基于时间序列的海量网络流量分析系统的研究与实现

作者：谭铖北京邮电大学

学位级别：硕士

近年来,随着互联网的高速发展,各种网络应用层出不穷,中国乃至全球的互联网使用人数与日俱增。据CCNIC发布的第36次中国互联网络发展状况统计报告,截至2015年6月,中国网民规模达6.68亿,半年内总计新增网民1894万人。互联网普及率为48.8... 详细信息

近年来,随着互联网的高速发展,各种网络应用层出不穷,中国乃至全球的互联网使用人数与日俱增。据CCNIC发布的第36次中国互联网络发展状况统计报告,截至2015年6月,中国网民规模达6.68亿,半年内总计新增网民1894万人。互联网普及率为48.8%。随着互联网的越来越普及,人们在日常生活中和互联网之间的联系也越来越紧密,互联网产生的网络流量数据也越来越大。对于这些包含个人信息的海量网络流量数据,如何对其进行处理、分析及存储也是运营商关心的一大难题。Hadoop的出现在一定程度上解决了海量网络流量数据的处理这个难题,但是随之新的问题出现了。Hadoop的批处理机制使得其更适合处理海量的离线数据,而对于实时的海量数据处理,则表现不尽人意。而Storm流处理平台的出现刚好弥补了 Hadoop实时性不足的缺点,成为大数据时代实时海量数据处理的新利器。本文首先介绍了海量网络流量的大环境,包括异常网络流量的危害以及异常检测研究现状。接着,介绍了大数据处理的一些相关技术。随后,分析了传统的异常网络流量检测法的不足,并在充分了解网络流量的时间序列性之后,提出将格拉布斯异常值检测法和动态K近邻相结合的新型检测算法,作为异常流量实时检测的算法,并对算法合理性和正确率进行了验证。之后,详细介绍了异常流量实时监测系统,包括kafka消息系统,Storm流处理平台和Hbase非关系型数据库,以及基于K近邻-格拉布斯检测法在这套Storm框架系统下的实现。最后,本文对异常网络流量实时检测系统的实验所得数据进行了分析。本文所有的数据均来自于某省的两千多家企业网的日常真实流量,所以可以保证数据的真实性和海量性。本文中所有的测试也都是在自主搭建的Storm实时处理平台上完成的。并且,实验数据结果显示,这套系统能够正确的完成异常流量的实时监测的任务。

关键词：实时流量异常检测 Storm kafka 复合会话

城市公交车辆信息实时监控关键技术研究及实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

城市公交车辆信息实时监控关键技术研究及实现

作者：王军峰河南工业大学

学位级别：硕士

近年来,随着城市规模扩大、人口增多、车辆增加及线路的丰富,传统公交实时监控系统已无法满足人们日益增长的公交服务实际需求。例如,郑州市早期采用的公交实时监控系统对车辆实时信息及特殊情况难以掌握与应对,造成资源浪费及乘客出行... 详细信息

近年来,随着城市规模扩大、人口增多、车辆增加及线路的丰富,传统公交实时监控系统已无法满足人们日益增长的公交服务实际需求。例如,郑州市早期采用的公交实时监控系统对车辆实时信息及特殊情况难以掌握与应对,造成资源浪费及乘客出行时长增加,尤其在高峰时段,车辆运行速度缓慢,车内拥挤等问题严重影响了乘客的舒适度和便捷度。论文首先对郑州市公交车辆信息实时监控系统进行了分析,探讨了系统目前存在的问题,如模块之间耦合度高、通信服务器并发能力低、数据库实时性不足、系统不稳定等;然后在此基础上,研究并设计了一个以HAProxy为代理服务,Netty为高性能通信框架,kafka为分布式消息缓存中间件,Redis为内存性数据库的系统架构;以此实现了一个具有耦合度低、实时性、高并发、高可用的车辆信息实时监控系统。其中,HAProxy采用负载均衡算法将车载终端请求转发给后台通信服务器,同时检测后台服务器活跃状态,保证了通信服务器高并发、负载均衡、高可用等特性;kafka利用其低时延、高吞吐量、数据可持久化的特性降低了模块之间耦合度;Redis利用其基于内存存储、高性能的特点,提高实时性数据的查询性能。此系统各模块相对独立、功能单一,在完善基础功能需求的同时,亦提升了整个系统的性能。测试实验表明,本文设计实现的公交车辆信息实时监控系统可通过网络将车辆的基本信息、定位信息等数据实时上传至监控平台,为公交调度管理系统提供更可靠的决策依据,可进一步提高车辆运行正点率和乘客满意度,以期获得良好的经济和社会效益。

关键词：城市公交实时监控 kafka Netty Redis 高并发

基于Storm的设备日志流数据实时处理系统的设计与实现

在线全文

同方学位论文库

学校读者我要写书评

暂无评论

基于Storm的设备日志流数据实时处理系统的设计与实现

作者：薛允臻南京大学

学位级别：硕士

随着物联网技术的兴起,工业企业中机器和传感器等设备每时每刻都在产生海量的设备日志数据。这些数据具有实时性强且没有止境的特点。工业企业需要深入挖掘这些设备日志流数据中的潜在价值,来提高企业效益。当前工业企业中采用是基于Had... 详细信息

随着物联网技术的兴起,工业企业中机器和传感器等设备每时每刻都在产生海量的设备日志数据。这些数据具有实时性强且没有止境的特点。工业企业需要深入挖掘这些设备日志流数据中的潜在价值,来提高企业效益。当前工业企业中采用是基于Hadoop的设备日志数据处理系统,这类系统从数据库中直接获取静态的日志数据,并对数据进行离线处理。系统虽然吞吐量高,但由于响应时间没有保障,只适合对海量静态日志数据做批处理,无法满足处理设备日志流数据的实时性需求。流数据计算框架Storm的出现,让实时处理设备日志流数据成为可能,但Storm采用单个控制节点来负责整个集群任务分配、代码分发和监控等工作,当控制节点宕机之后,提交给集群的拓扑任务便无法执行,集群系统存在单节点失效性问题。本文针对目前设备日志数据处理系统中存在的实时性问题和单节点失效性问题,设计并实现了基于Storm的设备日志流数据实时处理系统。首先,针对实时性问题,系统采用Storm作为日志流数据处理的框架,省去批处理的数据收集时间和作业调度时间,让系统的响应时间缩短。同时系统在对日志流数据处理时,增加滑动时间窗口,只对时间窗内的日志流数据进行处理,保证了处理数据的实时性。其次,针对单点失效问题,系统采用主-从多个控制节的优化集群,在保证了集群多个从控制节点与当前主控制节点信息同步的基础上,利用Zookeeper集群的协调机制,在主控制节点宕机后,从控制节点利用竞选方式产生新的主控制节点,保证即使集群中主控制节点发生故障,其中一个从控制节点也会接管继续运行拓扑任务。本系统以可视化的方式将实时处理后的结果展示给工业企业的车间人员,旨在让车间人员通过使用本系统完成对车间设备运行状态的实时跟踪与监控,帮助工业企业智慧化管理车间的机器设备,进而提高企业生产效率,节约生产成本。

关键词：流式计算大数据 Storm kafka Zookeeper HBase