flume - 我可以在水槽配置中使用系统属性吗

Question

我有以下水槽配置用于水槽水槽

# Describe the sink
a1.sinks.k1.type = file_roll
a1.sinks.k1.sink.directory = ~/flume_file_sink
a1.sinks.k1.rollInterval = 0

我想 make sink.directory, channels.c1.capacity, channels.c1.capacitymake 可配置（假设使用系统属性）。可以这样做。

Answer 1

AFAIK，这是不可能的。

文档说：

Flume 代理配置存储在本地配置文件中。这是一个遵循 Java 属性文件格式的文本文件。

如果不仅模仿了格式，而且模仿了行为，那么您将无法在 Flume 的配置文件中进行变量替换（请参阅属性文件：使用键作为变量）。

Answer 2

与您想要做的最相似，虽然没有那么有效的是 Exec Source

https://flume.apache.org/FlumeUserGuide.html#exec-source

您可以执行诸如 tail -F /var/log/secure 之类的 unix 命令

我希望能帮助你