GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/3983
KAFKA-5986: Streams State Restoration never completes when logging is
disabled
When logging is disabled and there are state stores the task never
transitions from restoring to running. This is because we only ever check if
the task has state stores and return false on initialization if it does. The
check should be if we have changelog partitions, i.e., we need to restore.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka restore-test
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3983.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 #3983
----
commit c60856362a9dfe1f8b68d76cbb5a783eef6abfff
Author: Damian Guy <[email protected]>
Date: 2017-09-28T11:52:34Z
fix task initialization when logging disabled
----
---
