storm笔记 与kafka的集成

   storm与kafka的结合,即前端的采集程序将实时数据源源不断采集到队列中,而storm做为消费者拉取计算,是典型的应用场景。所以,storm的发布包中也包含了一个集成jar,支持从kafka读出数据,供storm应用使用。这里结合本身的应用作个简单总结。前端   因为storm已经提供了storm-kafka,所以能够直接使用,使用kafka的低级api读取数据。若是有须要的话,本身实现
相关文章
相关标签/搜索