我有以下水槽水槽的水槽配置
# Describe the sink
a1.sinks.k1.type = file_roll
a1.sinks.k1.sink.directory = ~/flume_file_sink
a1.sinks.k1.rollInterval = 0
Run Code Online (Sandbox Code Playgroud)
我想使sink.directory, channels.c1.capacity,channels.c1.capacity变得可配置(假设使用系统属性)。这样做是可能的。
AFAIK,这是不可能的。
文档说:
Flume 代理配置存储在本地配置文件中。这是一个遵循 Java 属性文件格式的文本文件。
如果不仅格式被模仿,行为也被模仿,那么您将无法在 Flume 的配置文件中进行变量替换(请参阅属性文件:使用 key 作为变量)。