You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by guozhangwang <gi...@git.apache.org> on 2017/10/18 01:28:13 UTC
[GitHub] kafka pull request #4086: HOTFIX: Normal poll with zero during restoration
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4086
HOTFIX: Normal poll with zero during restoration
Mirror of #4085 against trunk.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KHotfix-restore-only
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4086.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 #4086
----
commit 9f4a0e9e4b88929901b26d8599b63333f5fbecac
Author: Guozhang Wang <wa...@gmail.com>
Date: 2017-10-18T01:27:35Z
normal poll with zero during restoration
----
---
[GitHub] kafka pull request #4086: [WIP] KAFKA-6085: Pause all partitions before task...
Posted by guozhangwang <gi...@git.apache.org>.
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4086
---
[GitHub] kafka pull request #4086: [WIP] KAFKA-6085: Pause all partitions before task...
Posted by guozhangwang <gi...@git.apache.org>.
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4086
---
[GitHub] kafka pull request #4086: [WIP] KAFKA-6085: Pause all partitions before task...
Posted by guozhangwang <gi...@git.apache.org>.
GitHub user guozhangwang reopened a pull request:
https://github.com/apache/kafka/pull/4086
[WIP] KAFKA-6085: Pause all partitions before tasks are initialized
Mirror of #4085 against trunk. This PR contains two fixes (one major and one minor):
Major: on rebalance, pause all partitions instead of the partitions for tasks with state stores only, so that no records will be returned in the same `pollRecords()` call.
Minor: during the restoration phase, when thread state is still PARTITION_ASSIGNED, call consumer.poll with hard-coded pollMs = 0.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KHotfix-restore-only
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4086.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 #4086
----
commit 62bf4784779f7379e849289c4456363f352cb850
Author: Guozhang Wang <wa...@gmail.com>
Date: 2017-10-12T21:18:46Z
dummy
commit 5726e39cba8a79e6858e8b932c5116b60f2ae314
Author: Guozhang Wang <wa...@gmail.com>
Date: 2017-10-12T21:18:46Z
dummy
fix issues
Remove debugging information
commit 8214a3ee340791eb18f7e5fa77f2510470cf977a
Author: Matthias J. Sax <ma...@confluent.io>
Date: 2017-10-17T00:38:31Z
MINOR: update exception message for KIP-120
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #4078 from mjsax/hotfix-streams
commit 637b76342801cf4a32c9e65aa89bfe0bf76c24a7
Author: Jason Gustafson <ja...@confluent.io>
Date: 2017-10-17T00:49:35Z
MINOR: A few javadoc fixes
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #4076 from hachikuji/javadoc-fixes
commit f57c505f6e714b891a6d30e5501b463f14316708
Author: Damian Guy <da...@gmail.com>
Date: 2017-10-17T01:01:32Z
MINOR: add equals to SessionWindows
Author: Damian Guy <da...@gmail.com>
Reviewers: Guozhang Wang <wa...@gmail.com>, Matthias J. Sax<ma...@confluent.io>, Bill Bejeck <bi...@confluent.io>
Closes #4074 from dguy/minor-session-window-equals
commit 2f1dd0d4da24eee352f20436902d825d7851c45b
Author: Guozhang Wang <wa...@gmail.com>
Date: 2017-10-18T01:27:35Z
normal poll with zero during restoration
commit 043f28ac89b50f9145ac719449f03a427376dcde
Author: Guozhang Wang <wa...@gmail.com>
Date: 2017-10-19T04:58:36Z
recheck state change
----
---