Efrat Levitan created FLINK-39234:
-------------------------------------
Summary: KafkaWriterFaultToleranceITCase flakiness due to
NotLeaderOrFollowerException
Key: FLINK-39234
URL: https://issues.apache.org/jira/browse/FLINK-39234
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka, Tests
Reporter: Efrat Levitan
tests in KafkaWriterFaultToleranceITCase fail due
to`org.apache.kafka.common.errors.NotLeaderOrFollowerException` thrown instead
of other expected exceptions:
{code:java}
2026-03-09T20:53:50.7773820Z [ERROR]
org.apache.flink.connector.kafka.sink.KafkaWriterFaultToleranceITCase.testFlushExceptionWhenKafkaUnavailable
Time elapsed: 6.008 s <<< FAILURE!
2026-03-09T20:53:50.7775290Z java.lang.AssertionError:
2026-03-09T20:53:50.7775562Z
2026-03-09T20:53:50.7775908Z Expecting actual throwable to be an instance of
any of the following types:
2026-03-09T20:53:50.7776654Z [org.apache.kafka.common.errors.NetworkException,
2026-03-09T20:53:50.7777307Z
org.apache.kafka.common.errors.TimeoutException]
2026-03-09T20:53:50.7778036Z but was:
2026-03-09T20:53:50.7779801Z
org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests
intended only for the leader, this error indicates that the broker is not the
current leader. For requests intended for any replica, this error indicates
that the broker is not a replica of the topic partition.
2026-03-09T20:53:50.7788393Z
2026-03-09T20:53:50.7789580Z at
org.apache.flink.connector.kafka.sink.KafkaWriterFaultToleranceITCase.testFlushExceptionWhenKafkaUnavailable(KafkaWriterFaultToleranceITCase.java:93)
2026-03-09T20:53:50.7792426Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2026-03-09T20:53:50.7793169Z at
java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
2026-03-09T20:53:50.7793939Z at
java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
{code}
example failure
https://github.com/apache/flink-connector-kafka/actions/runs/22686855351/job/66358437651?pr=234
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
