我正在通过负载均衡器接收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
我用的是正确的车辆吗?或者我应该使用解析器?有什么想法吗?
1条答案
按热度按时间pcww981p1#
尝试以下配置。