guozhangwang commented on PR #12386: URL: https://github.com/apache/kafka/pull/12386#issuecomment-1188363535
> Currently, it is not clear to me if we also need to consider the case were a task is paused before it is added to the state updater? Such a situation might happen when a Kafka Streams client is paused before it is started which is legit according to KIP-834. Yes this is a good question. Currently I'm thinking to not complicate the logic of state updater but handling such cases outside, a.k.a. in task manager, when tasks are not being created we keep the pause status book-kept inside the task managers (potentially in the pending tasks structure as well). -- 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
