GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3769
MINOR: Log encountered exception during rebalance
Some other minor changes:
1. Do not throw the exception form callback as it would only be swallowed
by consumer coordinator; remembering it and re-throw in the next loop is good
enough.
2. Change Creating to Defining in Stores to avoid confusions that the
stores have already been successfully created at that time.
3. Do not need unAssignChangeLogPartitions as the restore consumer will be
unassigned already inside changelog reader.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
KMinor-logging-before-throwing
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3769.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 #3769
----
commit 2a83edbfd14cce427a79f94924b56e54cd97c03d
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-08-31T03:17:28Z
minor fixes
commit b302ab47911822bd3e3056254caade73057896d5
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-08-31T17:02:32Z
unit test fixes
----
---
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.
---
