kafka同一個topic和gruopid下的雙flume客戶端消費測試

業務場景:單個flume客戶端無法消費某個數據量很大的topic,因此起兩個flume去消費同一個topic 數據流:kafka--->flume---->oss(阿里雲的分佈式存儲服務,可以是hdfs) 01.conf 和 02.conf配置的topic和group.id以及數據存儲路徑都保持一致,不同的是文件前綴  01.conf配置 02.conf配置 我這邊在kafka的生產端生產了少量的
相關文章
相關標籤/搜索