GitHub user zhuoliu opened a pull request:
https://github.com/apache/storm/pull/572
[STORM-826] Update KafkaBolt to use the new kafka producer API
1. Modify KafkaBolt to use the new KafkaProducer API (8.2 up) and long term
supported kafka APIs
2. Support asynchronous message sending with callback
3. Update KafkaBoltTest correspondingly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhuoliu/storm storm826
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/572.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 #572
----
commit d605a2d0c3af8dbc3c897cae829ef318e7d4b5f4
Author: zhuol <[email protected]>
Date: 2015-05-27T15:48:39Z
storm-826, update KafkaBolt to use the new kafka producer APIs
Deal with producer can not clase issue
Able to pass unit tests and add callback async
commit 0599551957947dbcc602436a69bd879f18a6a1fb
Author: zhuol <[email protected]>
Date: 2015-06-02T15:22:54Z
Cleanup
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
