0

我们如何在没有logstash和beats的情况下通过java将数据摄取到弹性搜索有没有像kafka这样的选项或者像只使用java而不使用任何工具的东西

4

1 回答 1

0

我不确定您为什么不想考虑 Filebeats --> Elastic。但是，是的，还有其他方法可以将您的日志发送到 Elastic 搜索。

另外，您没有提及来源是什么，是否要插入应用程序日志，数据库。假设您还想发送微服务日志，并且以下选项也适用于发送其他数据。

由于您不想使用 Filebeat，您应该添加自定义代码来收集、提炼、格式化和发布日志。

  • 您可以使用 Kafka Sink Connector 到 Elastic 搜索来移动所有日志
  • 此外，您可以使用 UDP 协议发送（客户端）日志和侦听（服务器），然后实现缓冲和摄取到 Elastic。

您可以开发一个包含所有这些代码并在所有 Java 应用程序中使用的公共库。

简单的 udp 客户端服务器代码 - https://github.com/suren03/udp-server-client

于 2020-08-12T23:59:19.627 回答