Lucas Brutschy created KAFKA-14530:
--------------------------------------
Summary: Check state updater more than once in process loops
Key: KAFKA-14530
URL: https://issues.apache.org/jira/browse/KAFKA-14530
Project: Kafka
Issue Type: Task
Components: streams
Reporter: Lucas Brutschy
In the new state restoration code, the state updater needs to be checked
regularly by the main thread to transfer ownership of tasks back to the main
thread once the state of the task is restored. The more often we check this,
the faster we can start processing the tasks.
Currently, we only check the state updater once in every loop iteration of the
state updater. And while we couldn't observe this to be strictly not often
enough, we can increase the number of checks easily by moving the check inside
the inner processing loop. This would mean that once we have iterated over
`numIterations` records, we can already start processing tasks that have
finished restoration in the meantime.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
