java - 以编程方式配置 Filebeat Shippers

标签 java shell filebeat

如何以编程方式创建类似 Filebeat 的 Shipper,它将我的日志从客户端服务器发送到远程 Logstash 服务器。

我是 ELK 和 log4j 的新手,我正在尝试创建 Daemonize java 程序或 shell 脚本,它将继续逐行读取我的日志文件,并将所有行(以及任何新行)发送到定义的 Logstash 服务器。

我能够逐行读取文件,但到达 EOF 后它就会关闭。

此外,我想让它成为守护进程,它将继续监视日志文件,并通过 TCP 将每一行发送到 Logstash。

FileInputStream fstream = new FileInputStream("textfile.txt");
BufferedReader br = new BufferedReader(new InputStreamReader(fstream));

String strLine;
while ((strLine = br.readLine()) != null)   {

  System.out.println (strLine);
}
br.close();

有人可以指导我正确的方向吗?

最佳答案

现在,

Filebeat确实存在,无需编程,只需使用beat包即可

https://www.elastic.co

关于java - 以编程方式配置 Filebeat Shippers,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37205379/

相关文章:

elasticsearch - 为什么Elasticsearch ignore_malformed将格式错误的值添加到索引?

elasticsearch - ELK堆栈中的Logstash和Filebeat

java - 每次测试前运行方法

java - JNA 如何将结构从 Java 传递到 C++ 方法?

linux - 使用 grep 检查文本文件中的 2 个精确字符串

linux - 自动更改bash脚本中的变量

elasticsearch - 从 filebeat 到 logstash 的连接被拒绝

JavaFX TextField cancelEdit 未按预期工作

java - 为 getStackTrace()[2].getMethodName() 获得不同的结果

bash - 为什么正确的 shell 脚本会给出包装/截断/损坏的错误消息?