https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java#L1345
This Line: log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor .activeTasks()); The parameter is active task, but the info content is standby tasks. This should be change to log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor .standbyTasks());