root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

MINOR: Fix misleading log-line (#14643) 

After finishing restoration, we should only log the active tasks. Standby tasks are not part of restoration and it can be confusing to see them show up on this log message.

Reviewers: Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
Lucas Brutschy 2023-10-26 17:31:46 +02:00 committed by Matthias J. Sax
parent af228ca84f
commit a593d8ac30
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
View File

@ -899,8 +899,8 @@ public class StreamThread extends Thread {
log.debug("State is {}; initializing tasks if necessary", stateSnapshot); log.debug("State is {}; initializing tasks if necessary", stateSnapshot);
if (taskManager.tryToCompleteRestoration(now, offsetResetter)) { if (taskManager.tryToCompleteRestoration(now, offsetResetter)) {
log.info("Restoration took {} ms for all tasks {}", time.milliseconds() - lastPartitionAssignedMs, log.info("Restoration took {} ms for all active tasks {}", time.milliseconds() - lastPartitionAssignedMs,
taskManager.allTasks().keySet()); taskManager.activeTaskIds());
setState(State.RUNNING); setState(State.RUNNING);
} }