Building a Stream Processing Pipeline (Node.js, Kinesis Firehose, ElasticSearch) (engineering.deltax.com)