Rohan Desai created KAFKA-16955:
-----------------------------------
Summary: ConcurrentModification exception thrown by KafkaStream
threadState access
Key: KAFKA-16955
URL: https://issues.apache.org/jira/browse/KAFKA-16955
Project: Kafka
Issue Type: Bug
Reporter: Rohan Desai
We see occasional ConcurrentModificationExceptions thrown when accessing
threadState:
{code:java}
155.745service_application1 info[ERROR] 2024-06-11 07:56:42.417
[e2e-de9a85a4-b1d9-4807-bc34-e269f760bcd7-StreamThread-2]
ResponsiveKafkaStreams - stream-client
[e2e-de9a85a4-b1d9-4807-bc34-e269f760bcd7] Replacing thread in the streams
uncaught exception handler155.745service_application1
infoorg.apache.kafka.streams.errors.StreamsException:
java.util.ConcurrentModificationException155.745service_application1 info
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:729)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:645)
[kafka-streams-3.7.0.jar:?]155.745service_application1 infoCaused by:
java.util.ConcurrentModificationException155.745service_application1 info at
java.util.HashMap$HashIterator.nextNode(HashMap.java:1605)
~[?:?]155.745service_application1 info at
java.util.HashMap$ValueIterator.next(HashMap.java:1633)
~[?:?]155.745service_application1 info at
org.apache.kafka.streams.KafkaStreams$StreamStateListener.maybeSetRunning(KafkaStreams.java:656)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.KafkaStreams$StreamStateListener.onChange(KafkaStreams.java:686)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.processor.internals.StreamThread.setState(StreamThread.java:261)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.processor.internals.StreamThread.initializeAndRestorePhase(StreamThread.java:1120)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.processor.internals.StreamThread.runOnceWithoutProcessingThreads(StreamThread.java:921)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:686)
~[kafka-streams-3.7.0.jar:?]155.745service_application1 info ... 1 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
