bug: Kafka Cluster Filter CR has a missing brace. #872
Description
Describe the issue
When Kafka output plugin is enabled in fluentd via values.yaml, fluentd is throwing error that the corresponding Filter for kafka does not have a valid expression/value .
To Reproduce
Enable Kafka using values.yaml.
fluentd:
output:
kafka:
enable: true
brokers: "cloudflow-strimzi-kafka-bootstrap.cloudflow.svc:9092"
topicKey: app
defaultTopic: app
useEventTime: true
Check the fluentd-0 logs. Throws ruby issue for the missing brace in ClusterFilter.
kubectl edit clusterfilters.fluentd.fluent.io fluentd-filter
value: ${record["kubernetes"]["namespace_name"]
Expected behavior
The filter expression should be valid as below
value: ${record["kubernetes"]["namespace_name"]}
fluentd should be running without errors and forward logs successfully to kafka endpoint
Your Environment
- Fluent Operator version: v1.6.1
- Container Runtime:
NAME="Red Hat Enterprise Linux"
VERSION="8.4 (Ootpa)"
ID="rhel"
ID_LIKE="fedora"
VERSION_ID="8.4"
- Operating system: Kubernetes 1.27
- Kernel version: 4.18.0-305.el8.x86_64How did you install fluent operator?
helm install fluent-operator https://github.com/fluent/fluent-operator/releases/download/v1.6.1/fluent-operator.tgz -f values_updated.yaml
Additional context
No response