From 0dee099268523da0692dca2c3b4de6b680a9dd7b Mon Sep 17 00:00:00 2001
From: Riccardo Magliocchetti <riccardo.magliocchetti@gmail.com>
Date: Tue, 26 May 2026 08:45:36 +0200
Subject: [PATCH] tests: make
 test_kafka_consumer_ignore_topic_ongoing_transaction less flaky

Assisted-by: Cursor
---
 tests/instrumentation/kafka_tests.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tests/instrumentation/kafka_tests.py b/tests/instrumentation/kafka_tests.py
index 6d1c51be1..253f9c6b9 100644
--- a/tests/instrumentation/kafka_tests.py
+++ b/tests/instrumentation/kafka_tests.py
@@ -224,6 +224,8 @@ def delayed_send():
     thread = threading.Thread(target=delayed_send)
     thread.start()
     transaction = elasticapm_client.begin_transaction("foo")
+    # Give Kafka enough time to resolve offsets and deliver all delayed records before iteration stops.
+    consumer.config["consumer_timeout_ms"] = 2000
     for item in consumer:
         pass
     thread.join()