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

Question

我有以下用于水槽接收器的水槽配置

# 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使可配置(假设使用系统属性)。这样做是可能的。

Answer 1

AFAIK，这是不可能的。

文档 says :

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

如果不仅格式被模仿，行为也被模仿，那么您将无法在 Flume 的配置文件中进行变量替换(请参阅 Properties file : Use key as variable )。