Flume+HBase+Kafka集成与开发

     今天的内容是完成Flume+HBase+Kafka的集成开发。如下图红框中所示,节点1的Flume的source有两个:节点2和节点3的sink输出。节点1接收后进行预处理然后分别以AsyncHBaseSink(HBaseSink)和Kafka Sink的方式推送给HBase和Kafka进行离线数据处理和实时数据处理。   1.下载Flume源码并导入Idea开发工具   1)将apac
相关文章
相关标签/搜索