Emit new event after error is thrown

[fili.p...@gmail.com]

Hi guys,

I was wondering if it is possible to re-emit an event in order to go through the filter phase again but with a different tag - after "event_router.emit(tag, time, record)" has been called.

In particular, I am using fluent-plugin-concat and it flushes the buffer when the timeout expires. I would like to change the tag and parse the message differently.

I think I can handle this scenario using label but I am curious to understand if it possible to "feed" fluentd from a plugin.

Thanks,

Filippo

[Mr. Fiber]

> In particular, I am using fluent-plugin-concat and it flushes the buffer when the timeout expires. I would like to change the tag and parse the message differently.

Why need tag change?

> I think I can handle this scenario using label but I am curious to understand if it possible to "feed" fluentd from a plugin.

Yeah, concat plugin provides label feature for timeout so easy to process timeout events in other pipeline.

Masahiro

--
You received this message because you are subscribed to the Google Groups "Fluentd Google Group" group.
To unsubscribe from this group and stop receiving emails from it, send an email to fluentd+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.