如何通過在水槽

Question

參數我水槽配置文件

TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource 
TwitterAgent.sources.Twitter.channels = MemChannel 
TwitterAgent.sources.Twitter.consumerKey = xxxxx 
TwitterAgent.sources.Twitter.consumerSecret = xxx 
TwitterAgent.sources.Twitter.accessToken = xxx 
TwitterAgent.sources.Twitter.accessTokenSecret = xxx 
TwitterAgent.sources.Twitter.keywords = Avengers 

「關鍵字」屬性被硬編碼爲「復仇者」中這樣定義一個Twitter水槽源。我想讓這個屬性值變成一個變量，並在我啓動我的flume agent時傳遞它。我試過位置參數，但似乎沒有工作。

有關如何完成此任務的任何想法？

Answer 1

是的，代理功能在twitter源中丟失。我已經提交了一個正在等待接受的補丁。在此之前隨意從GitHub拉我的版本：

https://github.com/schmiegelow/flume/blob/trunk/flume-ng-sources/flume-twitter-source/src/main/java/org/apache/flume/source/twitter/TwitterSource.java

乾杯，

埃裏克