如何通过在水槽

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

干杯，

埃里克