GitHub user Parth-Brahmbhatt opened a pull request:
https://github.com/apache/storm/pull/387
Storm 631: refactoring kafka connector code.
This also covers STORM-590. I could not come up with a better name for
partitionCoordinator which is more like PartitionManagerCache but it also
handles Task to PartitionManager Mapping so any suggestions are welcome.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Parth-Brahmbhatt/incubator-storm STORM-631
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/387.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 #387
----
commit 9fc51c15565adb9a560f9612f616c2125b4e165c
Author: Parth Brahmbhatt <[email protected]>
Date: 2015-01-20T06:38:10Z
STORM-631: Refactoring storm-kafka connector.
commit 12eb96fc666a88d4906ce5b9215b6514858a58ce
Author: Parth Brahmbhatt <[email protected]>
Date: 2015-01-20T19:15:42Z
Merge remote-tracking branch 'upstream/master'
commit 1f732e895bbe1253139f93d9a32746057b234b2b
Author: Parth Brahmbhatt <[email protected]>
Date: 2015-01-20T19:25:45Z
STORM-631: Remvoing unintedend test files.
----
---
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.
---
