I have raised the same question at github, but looks like there is no interest.
The problem is about input plugin create the EVENT steam, but did not provide a way for the later filter or output to determine the work is done.
Anyone has any advise?
Thanks