From 6ec9c04c0309a77fd62e74d1d398284fb9cbabd0 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 11 Apr 2026 09:35:18 -0700 Subject: [PATCH] increase consumer_timeout_ms=30000 for test_kafka_consumer --- test/integration/test_consumer_integration.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/test/integration/test_consumer_integration.py b/test/integration/test_consumer_integration.py index 4c63ac297..04ce51578 100644 --- a/test/integration/test_consumer_integration.py +++ b/test/integration/test_consumer_integration.py @@ -56,7 +56,9 @@ def test_kafka_version_infer(kafka_consumer_factory): def test_kafka_consumer(kafka_consumer_factory, send_messages): """Test KafkaConsumer""" - consumer = kafka_consumer_factory(auto_offset_reset='earliest', consumer_timeout_ms=2000) + # consumer_timeout_ms must exceed worst-case broker+CI latency for 200 + # records; 30s gives plenty of margin without masking real hangs. + consumer = kafka_consumer_factory(auto_offset_reset='earliest', consumer_timeout_ms=30000) send_messages(range(0, 100), partition=0) send_messages(range(0, 100), partition=1) cnt = 0