GitHub user guozhangwang reopened a pull request:
https://github.com/apache/kafka/pull/4085
HOTFIX: poll with zero millis during restoration
Mirror of #4096 for 0.11.01.
During the restoration phase, when thread state is still in
PARTITION_ASSIGNED not RUNNING yet, call poll() on the normal consumer with 0
millisecond timeout, to unblock the restoration of other tasks as soon as
possible.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KHotfix-0110-restore-only
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4085.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 #4085
----
commit 941a567f0388b4c74d095c444165e4315ff5b9df
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-17T20:29:15Z
poll with zero millis during restoration
commit 01af809ba31857f6f68e19821d25d3cef5dd62c0
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-12T21:18:46Z
dummy
commit 6c7b512cf8fe93661aea55c2c0622b2064be5beb
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-19T05:19:02Z
github comments; fixes for double check
commit 2d26b4d64f6dce0f01a06c379af8c5823a8ed5b6
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-23T19:49:22Z
rebase from 0.11.0
commit 9b41200e6565af233389d2d7172348a881912cd3
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-23T19:53:01Z
github comments
commit c00143a42ae7cd0f460bd1254b7b65105c221e77
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-23T20:32:00Z
minor fixes post rebasing
commit d11b0373a8663705979d2e58681a81777657d90a
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-23T21:28:24Z
one minor fix
commit 379a727509a08ab0bf69e36af432c664acd355ca
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2017-10-23T21:30:12Z
cherry-pick fix from trunk
----
---
