GitHub user srdo opened a pull request: https://github.com/apache/storm/pull/2224
STORM-2542: Deprecate KafkaConsumer.subscribe API option, make KafkaConsumer.assign the default The first commit is from https://github.com/apache/storm/pull/2223. I'd like us to switch to using manual partitioning in 1.2.0 as the default rather than waiting for 2.0, since the subscribe API seems to cause people issues. It's not something I feel strongly about though, so if it's too big of a change for a minor version release, let me know and I'll revert it. You can merge this pull request into a Git repository by running: $ git pull https://github.com/srdo/storm STORM-2542-1.x Alternatively you can review and apply these changes as the patch at: https://github.com/apache/storm/pull/2224.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 #2224 ---- commit 955d317e330c8b4891bfb354c40d6f233a5404a1 Author: Stig Rohde Døssing <stigdoess...@gmail.com> Date: 2017-06-05T12:59:19Z STORM-2541: Fix storm-kafka-client manual subscription not being able to start consuming commit 86d805b31762693cc40396b617056b5de8014780 Author: Stig Rohde Døssing <s...@apache.org> Date: 2017-07-18T21:46:09Z STORM-2542: Deprecate storm-kafka-client subscribe APIs in 1.x commit 6777a86bf6edea9ebbaf205754b4c2777a20bfeb Author: Stig Rohde Døssing <stigdoess...@gmail.com> Date: 2017-06-05T12:59:19Z Cherry pick STORM-2542 commit 53d5a65758f40d4f6196f9bbb944d3678d5d4b99 Author: Stig Rohde Døssing <s...@apache.org> Date: 2017-07-19T10:07:21Z Backport to java 7 ---- --- 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---