Elastic search logstash

The CSV parsing failed. Not sure why but I'm sure the Logstash log contains details.

Why are you converting from JSON to CSV in your Node code instead of just serializing the data to JSON and have Logstash read that directly?