The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/FLINK-39699 has succeeded. Run started by GitHub user Savonitar (triggered by 1996fanrui).
Head commit for run: 5eda93178afd04fc5e47933a36257db01619104d / Aleksandr Savonin <[email protected]> [hotfix] Stabilize KafkaWriterFaultToleranceITCase exception-on-unavailable tests testFlush/testWrite/testCloseExceptionWhenKafkaUnavailable all rely on the producer still having undelivered work when KAFKA_CONTAINER.stop() takes effect. Under CI load the sender thread can ship and ack the buffered record before stop() returns, so the operation under test (flush/write/close) has nothing to fail on and the .rootCause() assertion fires with "Expecting actual not to be null" instead of seeing the expected NetworkException / TimeoutException. Drain a warm-up record before stopping the broker, then issue the real write while the broker is down. The producer's metadata is already cached so write() returns immediately; the sender fails to deliver (retries=0); the operation under test reliably surfaces the underlying exception. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/26090072750 With regards, GitHub Actions via GitBox
