logging - logstash/kibana中的子查询或类似查询？

Question

如果这是一个愚蠢的问题，我先为自己的无知向您道歉。

我遇到了一个应用程序问题，该应用程序显然异步接收消息并偶尔丢失响应。本质上，当一个客户端向该服务发布一条消息时，我会记录一次日志；而在响应时，则会记录另一个。这些日志条目包含一个唯一的相关性ID，我可以使用它来交叉引用请求和响应。我们将日志发送到logstash，我已经能够找到一些被已接收日志条目且没有回复的客户端捕获的日志。我完全不确定这将如何发生。

但是，我首先需要通过比较相关ID来确定此问题的范围。在转向logstash之前，我们使用了splunk，我能够使用它们的连接功能来找到这种相关性。是否可以通过logstash使用此功能？还是我可以进行API调用以将单个查询结果转储并运行自己的逻辑？

以前省略的
这是完整的ELK堆栈

TIA

Answer 1

今天我听说记录器消息可能会因线程而丢失。问题是使记录器无法使用注释@transient进行序列化
在scala中，这是代码

RegisterLogicalType.register

@transient protected lazy val logger: Logger =
  Logger(LoggerFactory getLogger getClass.getName)