we have telemetry output coming to logstash via kafka which we are splitting to three levels to get the required data out of it. Here, I see that filter block output is fine but when the output flow is sending data to elasticsearch it is just reusing last split event value in all the output messages. Example is given below: