Flume+HBase+Kafka集成與開發

     今天的內容是完成Flume+HBase+Kafka的集成開發。如下圖紅框中所示,節點1的Flume的source有兩個:節點2和節點3的sink輸出。節點1接收後進行預處理然後分別以AsyncHBaseSink(HBaseSink)和Kafka Sink的方式推送給HBase和Kafka進行離線數據處理和實時數據處理。   1.下載Flume源碼並導入Idea開發工具   1)將apac
相關文章
相關標籤/搜索