Flaky kafka-newest test on 3.14

```
____________________ test_kafka_consume_ongoing_transaction ____________________

instrument = None
elasticapm_client =
producer =
consumer =
topics = ['test', 'foo', 'bar']

def test_kafka_consume_ongoing_transaction(instrument, elasticapm_client, producer, consumer, topics):
def delayed_send():
time.sleep(0.2)
elasticapm_client.begin_transaction("foo")
producer.send("test", key=b"foo", value=b"bar")
producer.send("test", key=b"baz", value=b"bazzinga")
producer.flush()
elasticapm_client.end_transaction("foo")

thread = threading.Thread(target=delayed_send)
thread.start()
transaction = elasticapm_client.begin_transaction("foo")
for item in consumer:
pass
thread.join()
elasticapm_client.end_transaction("foo")
transactions = elasticapm_client.events[TRANSACTION]
assert len(transactions) == 2
external_spans = elasticapm_client.spans_for_transaction(transactions[0])
spans = elasticapm_client.spans_for_transaction(transactions[1])
assert len(external_spans) == 2
> assert len(spans) == 2
E assert 0 == 2
E + where 0 = len([])

consumer =
delayed_send = .delayed_send at 0x7f408c16c1a0>
elasticapm_client =
external_spans = [{'action': 'send', 'context': {'destination': {'address': 'kafka', 'port': 9092, 'service': {'name': 'kafka', 'resour...vice': {'target': {'name': 'test', 'type': 'kafka'}}}, 'duration': 0.48899999999999993, 'id': 'f964a73fb9260ef4', ...}]
instrument = None
producer =
spans = []
thread =
topics = ['test', 'foo', 'bar']
transaction =
transactions = [{'context': {'tags': {}}, 'duration': 12.602, 'id': '0a2d2ff318df135c', 'name': 'foo', ...}, {'context': {'tags': {}}, 'duration': 502.87899999999996, 'id': '60f261ba230a8914', 'name': 'foo', ...}]
```

Inizia eseguendo test_kafka_consume_ongoing_transaction su Python 3.14 e riproduci il fallimento dell'assertion segnalato. Traccia quindi il timing della transazione e del consumer Kafka del test, poi verifica che il test passi in modo affidabile con due span nella seconda transazione senza indebolire le sue assertion.

Scritto dal modello di indicizzazione a partire dal testo della issue.