[jira] [Created] (KAFKA-17354) StreamThread::setState race condition causes java.lang.RuntimeException: State mismatch PENDING_SHUTDOWN different from STARTING

[Ao Li (Jira)]

Ao Li created KAFKA-17354:
-----------------------------

             Summary: StreamThread::setState race condition causes 
java.lang.RuntimeException: State mismatch PENDING_SHUTDOWN different from 
STARTING
                 Key: KAFKA-17354
                 URL: https://issues.apache.org/jira/browse/KAFKA-17354
             Project: Kafka
          Issue Type: Bug
            Reporter: Ao Li


I saw a test failure in `StreamThreadTest::shouldChangeStateAtStartClose`. A 
race condition in `setState` causes an uncaught exception thrown in 
`StateListenerStub`. 

Basically, the function `setState` allows two threads to call 
`stateListener.onChange` concurrently. 

This patch will help you to reproduce the failure deterministically. 

https://github.com/aoli-al/kafka/commit/033a9a33766740e6843effb9beabfdcb3804846b



--
This message was sent by Atlassian Jira
(v8.20.10#820010)