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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to