I'm clueless why my re-emitted records are paused in the beginning of the pipeline, i.e. the INPUT section.
The config to reproduce (spared the SERVICE section):
[INPUT]
name stdin
[FILTER]
Name record_modifier
Match *
Record env prod
[FILTER]
Name rewrite_tag
Match *
Rule $env ^prod.* valid.prod true
Emitter_name re_emitted_valid
[OUTPUT]
Name stdout
match valid.*
No message reaches stdout.
The fluent-bit log output with relevant message marked is attached.
I can also output the metrics:
{
"input": {
"stdin.0": {
"records": 1,
"bytes": 749
},
"re_emitted_valid": {
"records": 0,
"bytes": 0
}
},
"filter": {
"record_modifier.0": {
"drop_records": 0,
"add_records": 0
},
"rewrite_tag.1": {
"drop_records": 0,
"add_records": 0,
"emit_records": 1
}
},
"output": {
"stdout.0": {
"proc_records": 0,
"proc_bytes": 0,
"errors": 0,
"retries": 0,
"retries_failed": 0
}
}
}