代码之家 › 专栏 › 技术社区 › okocki

如何使用apache flume从txt文件读取日志

flume-ng flume

0

okocki · 技术社区 · 8 年前

我的阅读能力在不断提高。使用flume的txt文件。我知道我可以使用例如

a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444

但是如何使用文本文件呢?我应该通过什么来代替netcat?

1 回复 | 直到 8 年前

1

Community Mohan Dere 7 年前

好的,我已经解决了。有必要在“config”文件中提供以下行:

a1.sources.r1.type = exec
a1.sources.r1.command = tail -F /path/to/file/
a1.sources.r1.channels = channel

而不是之前的配置文件,然后使用此配置文件调用flume ng。

推荐文章

user99999991 · Flume能否将ElasticSearch与Amazon Elastic Search服务结合使用?

8 年前

okocki · 如何使用apache flume从txt文件读取日志

8 年前

sarath endluri · 使用文件通道在水槽中耗尽可用空间

10 年前