fluentd问题中的过滤

2w3rbyxf  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(339)

我正在通过负载均衡器接收kafka集群(3个节点)的数据。除了我需要的nginx日志消息之外,loadbalancer还向我发送了一些ping消息,以查看kafka节点是否仍然存在。这些“ping”出现在我的Kafka主题中:

{"message":"A10\u0000"}

我一直在尝试过滤掉fluentd配置文件中的这些消息,但似乎我不能得到它的权利。
这是我的fluentd配置的一部分:

<source>
  @type udp
  <parse>
    @type none
  </parse>
  port 11514
  bind 0.0.0.0
  tag trb-login
</source>

<filter A10>
  @type grep
  @log_level debug
  <exclude>
    key message
    pattern A10
  </exclude>
</filter>

还为模式尝试了其他几个regexp,如^a10、^a10$、^a10*。甚至尝试了模式(a10\u0000)的全文,带有不同数量的反斜杠。没有什么能让我过滤掉这行(顺便说一下:@log_level调试也不做任何事情……)
我的fluentd版本是1.2.2
我用的是正确的车辆吗?或者我应该使用解析器?有什么想法吗?

pcww981p

pcww981p1#

尝试以下配置。

<filter>
    @type grep
    <exclude>
      key message
      pattern /^A10/
    </exclude>
  </filter>

相关问题