From f1b2ef2e9409a66590b3c2f9cbe4c99375fa1f08 Mon Sep 17 00:00:00 2001 From: Hugo-C Date: Tue, 14 Oct 2025 23:24:32 +0200 Subject: [PATCH 1/2] fix(redpanda): bump image version in test --- modules/kafka/tests/test_redpanda.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/kafka/tests/test_redpanda.py b/modules/kafka/tests/test_redpanda.py index 7cee9fa8a..93f108a71 100644 --- a/modules/kafka/tests/test_redpanda.py +++ b/modules/kafka/tests/test_redpanda.py @@ -13,7 +13,7 @@ def test_redpanda_producer_consumer(): produce_and_consume_message(container) -@pytest.mark.parametrize("version", ["v23.1.13", "v23.3.10"]) +@pytest.mark.parametrize("version", ["v23.1.13", "v25.3.6"]) def test_redpanda_confluent_version(version): with RedpandaContainer(image=f"docker.redpanda.com/redpandadata/redpanda:{version}") as container: produce_and_consume_message(container) From ae1cb02f96db749935222d8b1c6045310ef4c0af Mon Sep 17 00:00:00 2001 From: Hugo-C Date: Tue, 3 Feb 2026 23:14:16 +0100 Subject: [PATCH 2/2] fix(redpanda): Use wait strategy instead of deprecated wait_for_logs --- modules/kafka/testcontainers/kafka/_redpanda.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/modules/kafka/testcontainers/kafka/_redpanda.py b/modules/kafka/testcontainers/kafka/_redpanda.py index b49957d03..a8adc0e03 100644 --- a/modules/kafka/testcontainers/kafka/_redpanda.py +++ b/modules/kafka/testcontainers/kafka/_redpanda.py @@ -1,11 +1,12 @@ import os.path +import re import tarfile import time from io import BytesIO from textwrap import dedent from testcontainers.core.container import DockerContainer -from testcontainers.core.waiting_utils import wait_for_logs +from testcontainers.core.wait_strategies import LogMessageWaitStrategy class RedpandaContainer(DockerContainer): @@ -34,6 +35,7 @@ def __init__( self.redpanda_port = 9092 self.schema_registry_port = 8081 self.with_exposed_ports(self.redpanda_port, self.schema_registry_port) + self.wait_for: re.Pattern[str] = re.compile(r".*Started Kafka API server.*") def get_bootstrap_server(self) -> str: host = self.get_container_host_ip() @@ -70,7 +72,9 @@ def start(self, timeout=10) -> "RedpandaContainer": self.with_command(command) super().start() self.tc_start() - wait_for_logs(self, r".*Started Kafka API server.*", timeout=timeout) + wait_strategy = LogMessageWaitStrategy(self.wait_for) + wait_strategy.with_startup_timeout(timeout) + wait_strategy.wait_until_ready(self) return self def create_file(self, content: bytes, path: str) -> None: