【发布时间】:2017-12-20 09:31:03
【问题描述】:
我在使用 Flume 读取不断增长的 .txt 文件时遇到问题。我知道我可以使用例如从网上阅读一些东西
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444
但是如何处理文本文件呢?我应该通过什么来代替 netcat?
【问题讨论】:
我在使用 Flume 读取不断增长的 .txt 文件时遇到问题。我知道我可以使用例如从网上阅读一些东西
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444
但是如何处理文本文件呢?我应该通过什么来代替 netcat?
【问题讨论】:
好的,我已经解决了。有必要在“配置”文件中提供以下几行:
a1.sources.r1.type = exec
a1.sources.r1.command = tail -F /path/to/file/
a1.sources.r1.channels = channel
代替以前的,然后用这个配置文件调用flume-ng。
【讨论】: