如何使用阿帕奇水槽从txt文件中读取日志
我有阅读持续增长的问题。txt文件。我知道我可以从网上读到一些东西，比如说
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444
但是如何用文本文件做呢？我应该传递什么而不是netcat？
共有1个答案
好的，我已经解决了。有必要在“配置”文件中提供以下行：
a1.sources.r1.type = exec
a1.sources.r1.command = tail -F /path/to/file/
a1.sources.r1.channels = channel
而不是以前的，然后使用此配置文件调用Flume-ng。
-
我测试了Apache Flume将文件从本地传输到HDFS。但是，如果源文件来自多个服务器（将文件从不同服务器的本地传输到HDFS），我可以只运行一个Flume实例并将更多代理添加到Flume-conf.property中吗？ 如果可以，如何在 flume-conf.properties 中编辑以下参数： 还有，我怎样才能运行水槽？ 只能运行一个水槽。两个以上呢？
-
我创建了此代码以使用Apache POI读取excel文件的内容。我使用eclipse作为编辑器，但当我运行代码时，我的粗体行出现问题。有什么问题？excel的内容如下：
-
我正在使用 flume 1.8.0，它会自动关闭，任何人都可以帮助我。 在 JAVA 8 上运行 JAVA_OPTS=“-服务器 -Xms4g -Xmx4g” 配置在水槽中 使用以下命令启动 flume ./bin/flume-ng agent --conf conf --conf-file ./conf/flume-conf-postgresql.properties --name dfm-to
-
如何使用标题读取Excel文件(xlsx)阿帕奇POI，Spring Boot！！！。我知道我们可以使用行迭代器和单元格迭代器来读取。我想用标题阅读。 这就是我使用行迭代器和单元格迭代器读取xlsx文件的方式 但是如何使用标题阅读？ 法典： 参考 1 的图像： 参考图片2：
-
我试图从JMS源读取数据，并将它们推送到KAFKA主题中，几个小时后，我观察到推送到KAFKA主题的频率几乎为零，经过一些初步分析，我在FLUME日志中发现以下异常。 my flume显示max.request的当前设置值（在日志中）。尺寸为1048576，明显小于1399305，增加了此最大要求。大小可能会消除这些异常，但我无法找到更新该值的正确位置。 我的水槽。配置， 任何帮助都将不胜感激！！
-
我正在编写一个程序，使用一个文件中的30个分数，计算出最低、最高和平均分数。我很难理解如何编写循环语句来读取每个等级并更新最低/最高等级，并在读取下一个等级之前将该值添加到总和。 谢谢想出来了：