GitHub user wurstmeister opened a pull request:
https://github.com/apache/storm/pull/407
Storm 590: added Kafka API based partition reader
Following the discussion in https://github.com/apache/storm/pull/387 I've
prepared an alternative implementation that is backwards compatible
- Iâve isolated the use of the ```BrokerHosts``` interface and marked its
use as deprecated together with the zookeeper based code
- Iâve then added an implementation for API based partition information
(based on the implementation https://github.com/apache/storm/pull/387)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wurstmeister/incubator-storm STORM-590
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/407.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 #407
----
commit 25952471b6cee4abe7c772f75a6faed7d63ffb39
Author: Wurstmeister <[email protected]>
Date: 2015-02-01T22:04:41Z
STORM-590: refactored broker configuration
* deprectated use of BrokerHosts
* added KafkaFactory
Change-Id: I114ac4c4fcadfa6353916040be2b7e4e529834f9
commit 7f7042346bff2b87ec867228bec05e0ccf737bbd
Author: Wurstmeister <[email protected]>
Date: 2015-02-01T23:28:16Z
STORM-590: added kafka api based broker reader
Change-Id: I567b1bb6ec80f352de8942e429a15025db415bf5
commit 590b88212a9188ebefdcae2e145198a8a3eb07c8
Author: Wurstmeister <[email protected]>
Date: 2015-02-02T08:35:01Z
STORM-590: deprecated use of BrokerHosts interface
Change-Id: I81faae69e13bbef2db806db6bea11ad5948f94bf
commit d32082a405fde83d57b235702fde6fc83ae50ff4
Author: Wurstmeister <[email protected]>
Date: 2015-02-02T10:53:36Z
STORM-590: added test for API based reader
Change-Id: If5dbf75d5b194efd2b50733184d23d1802d40910
commit b1d014135e2a032baf859762ddb8e852ac34d800
Author: Wurstmeister <[email protected]>
Date: 2015-02-02T15:39:49Z
STORM-590: removed unintended change
Change-Id: Ic7a1c9a775b99451a9f045dd21913cb829857f31
commit e54a2eaad5e4e109519c9f5c841da1abf44899ef
Author: Wurstmeister <[email protected]>
Date: 2015-02-02T15:53:50Z
STORM-590: removed unnecessary call to KafkaConfig
Change-Id: Ia5b4819300945360fcd39addc94c87efa7d7103f
commit 51adadd77b60ed8023ef3a69b7f53f0f389e0ce1
Author: Wurstmeister <[email protected]>
Date: 2015-02-02T17:12:16Z
STORM-590: added more tests
Change-Id: I5fc3c1ccedd11df7d67a7f0dfb1bb00bc8790daf
----
---
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.
---
