avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412055008
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##########
@@ -305,6 +297,12 @@ public void resume() {
default:
throw new IllegalStateException("Illegal state " + state() + "
while resuming active task " + id);
}
+ if (requiresUpdate) {
+ partitionGroup.updatePartitions(inputPartitions(),
recordQueueCreator::createQueue);
+ if (state() != State.RESTORING) { // if task is RESTORING then
topology will be initialized in completeRestoration
Review comment:
when work on this task it fails some test that ensure that
initializeTopology called once here. I thought that it might be important and
decided to support this.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
