cadonna commented on code in PR #12554:
URL: https://github.com/apache/kafka/pull/12554#discussion_r955764822
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java:
##########
@@ -183,6 +185,21 @@ public int hashCode() {
*/
Set<StreamTask> getActiveTasks();
+ /**
+ * Returns if the state updater restores active tasks.
+ *
+ * The state updater restores active tasks if at least one active task was
added with the {@link StateUpdater#add(Task)}
Review Comment:
I am not sure what you mean with "if it is able to do so". The state updater
manages active tasks in restoration and standby task. This method should return
true, if there are non-paused active tasks somewhere in the state updater. The
return value is used to decide whether the stream thread can transit to
`RUNNING`.
I realised now that I forgot to add the non-paused part to the java docs.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
