如何在flume中传递参数

Question

我有一个 twitter flume 来源在 flume 配置文件中这样定义

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

'keywords' 属性被硬编码为 'Avengers'。我想使这个属性值成为一个变量，并在我启动 flume 代理时将其传入。我尝试了位置参数，但似乎不起作用。

关于如何完成这项工作有什么想法吗？

Answer 1

是的，twitter-source 中缺少代理功能。我已经提交了一个正在等待接受的补丁。在那之前，请随意从 github:

中提取我的版本

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

干杯，

埃里克

如何在flume中传递参数

How to pass parameters in flume

flume-ng

flume-twitter