From 3f80b6139796ca518a044022ad383ae304075a71 Mon Sep 17 00:00:00 2001 From: fulmicoton Date: Fri, 26 Dec 2025 18:04:09 +0100 Subject: [PATCH] This fixes two kafka flaky tests. The cause is complicated. When relying on localhost for connection, the client will first attempt ipv6 and then ipv4. This will cause a bunch of BrokerTransportFailure to be emitted by RdKafka. These errors will either fail the actor or fail the test assert. See #6049 --- quickwit/quickwit-indexing/src/source/kafka_source.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/quickwit/quickwit-indexing/src/source/kafka_source.rs b/quickwit/quickwit-indexing/src/source/kafka_source.rs index bc5b400a9bc..2129a12f4b9 100644 --- a/quickwit/quickwit-indexing/src/source/kafka_source.rs +++ b/quickwit/quickwit-indexing/src/source/kafka_source.rs @@ -872,6 +872,8 @@ mod kafka_broker_tests { fn get_source_config(topic: &str, auto_offset_reset: &str) -> (String, SourceConfig) { let source_id = append_random_suffix("test-kafka-source--source"); + // Setting explicitly ip v4 with `broker.address.family` is required + // because of https://github.com/fede1024/rust-rdkafka/issues/809 let source_config = SourceConfig { source_id: source_id.clone(), num_pipelines: NonZeroUsize::MIN, @@ -882,6 +884,7 @@ mod kafka_broker_tests { client_params: json!({ "auto.offset.reset": auto_offset_reset, "bootstrap.servers": "localhost:9092", + "broker.address.family": "v4", }), enable_backfill_mode: true, }),