Hi Samza folks, For people who want to use HTTP to integrate with Elasticsearch, I wrote an HTTP-based system producer and a reusable task, including latency stats from event origin time, task processing time, and time spent talking to Elasticsearch API.
https://github.com/quantiply/rico/blob/master/docs/common_tasks/es-push.md Cheers, Roger
