GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/2266
KAFKA-4540: Suspended tasks that are not assigned to the StreamThread need
to be closed before new active and standby tasks are created
During `onPartitionsAssigned` first close, and remove, any suspended
`StandbyTasks` that are no longer assigned to this consumer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka kafka-4540
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2266.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 #2266
----
commit 347ef4cb32c9e4ad6162160c7ba898f30941ea3c
Author: Damian Guy <[email protected]>
Date: 2016-12-15T16:15:24Z
fix standby task suspension
commit 4f5ab9d38c3049def0ce29cd7cb191db83069a12
Author: Damian Guy <[email protected]>
Date: 2016-12-16T08:39:06Z
merge trunk
commit 3def0307ae5185ba78b4c3ae90eafbbd50640a63
Author: Damian Guy <[email protected]>
Date: 2016-12-16T08:51:56Z
remove metrics etc from TestStreamTask
----
---
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.
---
