我想从flume中的不同服务器读取一个日志文件，该文件在不同的服务器上启动并运行…….为此，我如何通过更改flume-conf.properties文件来实现这一点…….我应该在flume的配置文件中编写什么来实现这一点。。。
a1.sources = AspectJ
a1.channels = memoryChannel
a1.sinks = kafkaSink
a1.sources.AspectJ.type = com.flume.MySource
a1.sources.AspectJ.command = tail -F /tmp/data/Log.txt为了达到这个目的，我应该写什么来代替a1.sources.aspectj.command=tail-f/tmp/data/log.txt
1条答案
按热度按时间xdyibdwo1#
我相信您想问的是，如果flume设置在主机“f”上，而您的日志文件存在于主机“l”上，您将如何配置flume以从主机“l”读取日志文件，对吗？
如果是这样，则需要在主机“l”上而不是“f”上设置Flume。在日志文件所在的主机上设置flume，并将接收器设置为指向kafka主题。