cadonna commented on a change in pull request #11499:
URL: https://github.com/apache/kafka/pull/11499#discussion_r749486443
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java
##########
@@ -0,0 +1,50 @@
+package org.apache.kafka.streams.processor.internals;
+
+import java.time.Duration;
+import java.util.List;
+
+public interface StateUpdater {
Review comment:
An implementation of the state updater is passed to the task manager in
its constructor. Since the threading model of the state updater is encapsulated
and one can pass the same state updater to multiple task managers there is no
fixed 1:1 relationship between a restoration thread and a stream thread.
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
