[
https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156254#comment-15156254
]
ASF GitHub Bot commented on STORM-822:
--------------------------------------
GitHub user hmcl opened a pull request:
https://github.com/apache/storm/pull/1131
STORM-822: Kafka Spout New Consumer API
This patch is still under development and was uploaded at this moment for
early testing. Please read README.
There may be a bug in the offsets management, because of diff o 1. I am
looking into it.
Currently polling from an arbitrary offset is possible but it will come in
the next patch, today or tomorrow
I refactored the code a bit and left, maybe, some unnecessary locking. I am
also looking into it.
@connieyang @jianbzhou @tgravescs please let me know of any other
requirements you may have and I will address them soon.
Thanks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hmcl/storm-apache STORM-822
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1131.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 #1131
----
commit bcabde29a0df7713b71d1807afec3be5b0147664
Author: Hugo Louro <[email protected]>
Date: 2015-12-14T18:16:42Z
STORM-822
- Storm Kafka Spout new consumer API
commit 92ae8a6aff4a1bd66c9153dcfd2c44d16de37637
Author: Hugo Louro <[email protected]>
Date: 2016-02-21T22:11:12Z
STORM-822
- Storm Kafka Spout new consumer API
----
> As a storm developer I’d like to use the new kafka consumer API (0.8.3) to
> reduce dependencies and use long term supported kafka apis
> --------------------------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-822
> URL: https://issues.apache.org/jira/browse/STORM-822
> Project: Apache Storm
> Issue Type: Story
> Components: storm-kafka
> Reporter: Thomas Becker
> Assignee: Hugo Louro
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
