[
https://issues.apache.org/jira/browse/STORM-826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14569279#comment-14569279
]
ASF GitHub Bot commented on STORM-826:
--------------------------------------
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
----
> As a storm developer I’d like to use the new kafka producer API to reduce
> dependencies and use long term supported kafka apis
> ------------------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-826
> URL: https://issues.apache.org/jira/browse/STORM-826
> Project: Apache Storm
> Issue Type: Story
> Components: storm-kafka
> Reporter: Thomas Becker
> Assignee: Zhuo Liu
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
