From e650de8d0390d48224cf74d1067d173f52b0bab2 Mon Sep 17 00:00:00 2001
From: Jarkko Jaakola <jarkko.jaakola@aiven.io>
Date: Wed, 25 Sep 2024 21:28:21 +0300
Subject: [PATCH] chore: update tests to use Kafka 3.4.1

---
 tests/conftest.py             | 2 +-
 tests/integration/conftest.py | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/conftest.py b/tests/conftest.py
index 99ba55809..960f07191 100644
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -15,7 +15,7 @@
 pytest_plugins = "aiohttp.pytest_plugin"
 KAFKA_BOOTSTRAP_SERVERS_OPT = "--kafka-bootstrap-servers"
 KAFKA_VERION_OPT = "--kafka-version"
-KAFKA_VERSION = "2.7.0"
+KAFKA_VERSION = "3.4.1"
 LOG_DIR_OPT = "--log-dir"
 VERSION_REGEX = "([0-9]+[.])*[0-9]+"
 
diff --git a/tests/integration/conftest.py b/tests/integration/conftest.py
index 04fbd7aa1..d77a665ce 100644
--- a/tests/integration/conftest.py
+++ b/tests/integration/conftest.py
@@ -79,7 +79,7 @@ def fixture_kafka_description(request: SubRequest) -> KafkaDescription:
         kafka_tgz=RUNTIME_DIR / kafka_tgz,
         install_dir=kafka_dir,
         download_url=kafka_url,
-        protocol_version="2.7",
+        protocol_version="3.4.1"
     )