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());

Reply via email to