IP屬地：廣東
-
17_Flume之面試題
面試官系列：談?wù)勀銓?duì)Flume的理解 (qq.com)[https://mp.weixin.qq.com/s/WwZkUkRaACgmtE-oZ...
-
16_Flume之源碼分析
Flume 1.9.0 源碼解析 : TailDirSource 全解flume taildir詳解張伯毅的博客-CSDN博客[https://...
-
15_Flume之TailSource源碼修改(修復(fù)Flume任務(wù)故障文件1. 問(wèn)題-Flume任務(wù)故障，文件重命名數(shù)據(jù)丟失 我們常用TailSource來(lái)監(jiān)聽(tīng)日志文件，被監(jiān)聽(tīng)的日志文件是常配置了按時(shí)間滾動(dòng)生成方式的嘹裂，...
-
14_Flume之事務(wù)Flume使用兩個(gè)獨(dú)立的事務(wù)分別負(fù)責(zé)從soucrce到channel臊旭，以及從channel到sink的event傳遞史翘。一旦事務(wù)中所有的event...
-
13_Flume之監(jiān)控1. 介紹 Flume自帶的有兩種監(jiān)控方式, http監(jiān)控和ganglia監(jiān)控钉迷，用戶(hù)還可以實(shí)現(xiàn)自定義的監(jiān)控出皇。 2. Http監(jiān)控 使用這種監(jiān)控...
-
12_Flume之連接ACL的Kafka
配置例子
-
11_Flume之啟動(dòng)任務(wù)腳本
1. 介紹 將Flume客戶(hù)端和真正任務(wù)配置的文件夾隔離開(kāi) 通過(guò)啟動(dòng)命令指定每個(gè)任務(wù)的執(zhí)行日志 真正任務(wù)配置中的可變參數(shù) 均采用傳參使用绸硕，用于生...
-
10_Flume之?dāng)r截器
1. 介紹 Inteceptor主要用來(lái)對(duì)event進(jìn)行過(guò)濾和修改堂竟，Interceptor可以將處理結(jié)果傳遞給下一個(gè)Interceptor從而形...
-
09_Flume之Sink的Processors
1. Sink Processor共有三種類(lèi)型 類(lèi)型DefaultSinkProcessor對(duì)應(yīng)單個(gè)sink魂毁，發(fā)送至單個(gè)sinkLoadBala...