TimeoutException is thrown as IllegalStateException in org.apache.kafka.streams.processor.internals.StreamTask#commitNeeded. Which causes the client to shutdown in org.apache.kafka.streams.KafkaStreams#getActionForThrowable. Could this be a bug exposed by change KAFKA-12887 which was introduced in …

Bug? TimeoutException is thrown as IllegalStateException causing client shutdown

mjsax 5 July 2022 16:30 2

As the comment in the code indicates, we should never hit a TimeoutException here. Can you reproduce the issue? Would be great if you could file a bug report with more details. Thanks!

Topic		Replies	Views
Kafka Streams Timeout During Partition Rebalance - Seeking Insights on NotLeaderOrFollowerException Kafka Streams	1	709	7 September 2024
Kafka streams application getting stuck after broker restarts Kafka Streams	3	4960	19 May 2021
Kafka-client doesn't recover automatically after timeout Java Clients	1	2339	21 May 2024
Handle Kafka exceptions like Cluster Authorised Exception such that steams client is not shutdown Kafka Streams	1	1929	22 May 2023
Kafka Producer time out during initTransactions while one broker is down Kafka Streams	3	5696	29 September 2023

Bug? TimeoutException is thrown as IllegalStateException causing client shutdown

Related topics