我有以下FlumeFlumeFlume配置
# Describe the sink a1.sinks.k1.type = file_roll a1.sinks.k1.sink.directory = ~/flume_file_sink a1.sinks.k1.rollInterval = 0
我想做点什么 sink.directory , channels.c1.capacity , channels.c1.capacity 使其可配置（例如使用系统属性）。这样做是可能的。
sink.directory
channels.c1.capacity
bqucvtff1#
最类似于您想要做的事情，尽管exec源代码没有那么有效https://flume.apache.org/flumeuserguide.html#exec-来源您可以执行类似tail-f/var/log/secure这样的unix命令我希望能帮助你
ds97pgxw2#
好吧，这是不可能的。文件上说：flume代理配置存储在本地配置文件中。这是一个遵循java属性文件格式的文本文件。如果不仅模仿了格式，还模仿了行为，那么就不能在flume的配置文件中进行变量替换（请参阅属性文件：使用key作为变量）。
2条答案
按热度按时间bqucvtff1#
最类似于您想要做的事情，尽管exec源代码没有那么有效
https://flume.apache.org/flumeuserguide.html#exec-来源
您可以执行类似tail-f/var/log/secure这样的unix命令
我希望能帮助你
ds97pgxw2#
好吧，这是不可能的。
文件上说：
flume代理配置存储在本地配置文件中。这是一个遵循java属性文件格式的文本文件。
如果不仅模仿了格式，还模仿了行为，那么就不能在flume的配置文件中进行变量替换（请参阅属性文件：使用key作为变量）。