GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/458
Refactoring the EventHub System Producer into reusable AsyncSystemProducer
and NoFlushAsyncSystemProducer
Refactoring eventhub system producer into common reusable components
1. AsyncSystemProducer : All the system producers that have real async send
API with call backs can use this
2. NoFlushAsyncSystemProducer: All the system producers that have real
async call back based send API and doesn't provide flush semantics can use this.
The system producers that implement AsyncSystemproducers can be used across
Samza and Brooklin.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srinipunuru/samza async-prod.3
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/458.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #458
----
commit aeb29e3aac4de0281d59a97d1662bfa15c241e66
Author: Srinivasulu Punuru <spunuru@...>
Date: 2018-03-27T22:24:19Z
Refactoring the EventHub System Producer into reusable AsyncSystemProducer
and NoFlushAsyncSystemProducer
----
---
