我是 Flume 的新手。我的要求是从 Java 代码启动 Flume 代理,配置如主机、端口等,当外部服务记录他们的数据时,它应该写在一个简单的文本文件中,例如 server.log。
我不想使用 HDFS 接收器。应该是什么配置?
我是 Flume 的新手。我的要求是从 Java 代码启动 Flume 代理,配置如主机、端口等,当外部服务记录他们的数据时,它应该写在一个简单的文本文件中,例如 server.log。
我不想使用 HDFS 接收器。应该是什么配置?
您可以使用File Roll Sink
,它将事件存储在本地文件系统中。您可以使用给定的配置示例作为配置的基础:
a1.channels = c1
a1.sinks = k1
a1.sinks.k1.type = file_roll
a1.sinks.k1.channel = c1
a1.sinks.k1.sink.directory = /var/log/flume
现在,您只需选择一个 Flume 源即可将事件放入c1
通道中。