oh. this is exciting. So you basically want a benthos stream with multiple inputs. one input that reads cyclic for a trigger and another input that reads the data block. Whenever the triggers is true it should read input 2 and send to the DB, otherwise it should drop the message? this should be doable in benthos. It is also similar to the alarm plugin i did for benthos which reads an input and listen to a specific part of the message as a trigger. the input 2 is an interval trigger that sends a message every second. When the alarm condition are meet it sends an alarm and the interval trigger is used to have a timer that resends the message after a specific time.. it should not be so complicated to rewrite the plugin to suit your needs. For the choking of the network, it feels like there is some bad configuration. Are you trying to push realtime data and not just data?