Hi, Roger, That's awesome! Are you planning to submit the HTTP-based system producer in Samza open-source samza-elasticsearch module? If ElasticSearch community suggest that HTTP-based clients be the recommended way, we should use it in samza-elasticsearch as well. And what's your opinion on the existing ElasticsearchSystemProducer? If the SystemProducer APIs and configure options do not change, I would vote to replace the implementation w/ HTTP-based ElasticsearchSystemProducer.
Thanks for putting this new additions up! -Yi On Tue, Feb 9, 2016 at 10:39 AM, Roger Hoover <roger.hoo...@gmail.com> wrote: > 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 >
