From 7040bf936a60cdbea4f07f80c5a82ab2d88a410c Mon Sep 17 00:00:00 2001 From: Max Pfeiffer Date: Tue, 9 Apr 2024 20:01:47 +0200 Subject: [PATCH] Switched default image to latest version with ARM support v5.4.3 was not supporting ARM CPUs. Removed an obsolet test. --- modules/kafka/testcontainers/kafka/__init__.py | 2 +- modules/kafka/tests/test_kafka.py | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/modules/kafka/testcontainers/kafka/__init__.py b/modules/kafka/testcontainers/kafka/__init__.py index 648140d4..7dd71b63 100644 --- a/modules/kafka/testcontainers/kafka/__init__.py +++ b/modules/kafka/testcontainers/kafka/__init__.py @@ -30,7 +30,7 @@ class KafkaContainer(DockerContainer): TC_START_SCRIPT = "/tc-start.sh" - def __init__(self, image: str = "confluentinc/cp-kafka:5.4.3", port: int = 9093, **kwargs) -> None: + def __init__(self, image: str = "confluentinc/cp-kafka:7.6.0", port: int = 9093, **kwargs) -> None: raise_for_deprecated_parameter(kwargs, "port_to_expose", "port") super().__init__(image, **kwargs) self.port = port diff --git a/modules/kafka/tests/test_kafka.py b/modules/kafka/tests/test_kafka.py index c47aa111..1f3826ad 100644 --- a/modules/kafka/tests/test_kafka.py +++ b/modules/kafka/tests/test_kafka.py @@ -14,11 +14,6 @@ def test_kafka_producer_consumer_custom_port(): produce_and_consume_kafka_message(container) -def test_kafka_confluent_7_1_3(): - with KafkaContainer(image="confluentinc/cp-kafka:7.1.3") as container: - produce_and_consume_kafka_message(container) - - def produce_and_consume_kafka_message(container): topic = "test-topic" bootstrap_server = container.get_bootstrap_server()