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"
     )