如何告诉流利者根据"logger_name"字段过滤日志？

Question

我的代码发布结构化日志，其中包含一个logger_name字段。这些日志随后通过fluentd发送到一些远程日志存储。我希望fluentd能够过滤来自Kafka流库的日志。尝试了这个配置，但是不工作:

<filter containers.**>
@type grep
<exclude>
key logger_name
pattern /org.apache.kafka.streams/
</exclude>
</filter>

我使用logback，并且AFAIK，它负责添加logger_name字段，所以我认为可以安全地假设当fluentd看到日志时，它们已经包含了这个字段。

过滤器不工作的原因是什么?

Answer 1

问题不在于语法，而在于模式字段:

pattern /org.apache.kafka.streams/

.应该转义，形成正确的模式:

pattern /org.apache.kafka.streams/

添加缺失的后，过滤器按预期工作。