Re: [PR] KAFKA-9972: Only commit tasks with valid states [kafka]

["Aatirhassanpir (via GitHub)" <gi...@apache.org>]

Aatirhassanpir commented on PR #8632:
URL: https://github.com/apache/kafka/pull/8632#issuecomment-2608834594

   Title
   KAFKA-9972: Only commit tasks with valid states
   
   Repository Version
   Apache Kafka Streams (version unknown, as PR details don’t specify)
   
   Key Words / Search Terms
   Task commit, invalid state, CREATED state, IllegalStateException, task validation, TaskManager, Kafka Streams
   
   Description
   During a soak test, it was observed that a standby task could enter the CREATED state during a commit operation. This resulted in an IllegalStateException, disrupting normal processing and causing runtime instability. The issue arises because the TaskManager does not currently validate the state of tasks before committing them.
   To resolve this issue, a state validation check must be implemented in the TaskManager. This check ensures that only tasks in valid states are committed, thereby preventing runtime errors caused by committing tasks in improper states like CREATED.
   
   Expected Behavior
   The TaskManager should commit only tasks that are in valid states.
   Invalid states such as CREATED should be skipped, preventing the IllegalStateException.
   
   Current Behavior
   The TaskManager attempts to commit tasks without validating their state.
   Tasks in invalid states, such as CREATED, trigger an IllegalStateException, causing processing disruptions.
   
   Steps to reproduce (for bug reports)
   Simulate a scenario where a standby task enters the CREATED state during a commit operation.
   Attempt to commit tasks using the current implementation of TaskManager.
   Observe the IllegalStateException triggered by the invalid state.
   Use cases / motivating examples (for feature requests)
   This fix ensures stable and reliable operation of Kafka Streams by:
   
   Preventing runtime errors caused by committing tasks in invalid states.
   Enabling smoother task handling during high-throughput operations.


-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org