diff --git a/karapace/kafka_rest_apis/__init__.py b/karapace/kafka_rest_apis/__init__.py
index 94d73f53b..ce82e5229 100644
--- a/karapace/kafka_rest_apis/__init__.py
+++ b/karapace/kafka_rest_apis/__init__.py
@@ -299,7 +299,7 @@ def init_admin_client(self):
                     api_version=(1, 0, 0),
                     metadata_max_age_ms=self.config["metadata_max_age_ms"],
                     connections_max_idle_ms=self.config["connections_max_idle_ms"],
-                    client_factory=KarapaceKafkaClient,
+                    kafka_client=KarapaceKafkaClient,
                 )
                 break
             except:  # pylint: disable=bare-except
diff --git a/karapace/karapace.py b/karapace/karapace.py
index 8b3ddd7f6..e6c14d9c7 100644
--- a/karapace/karapace.py
+++ b/karapace/karapace.py
@@ -55,7 +55,7 @@ def _create_producer(self):
                     metadata_max_age_ms=self.config["metadata_max_age_ms"],
                     max_block_ms=2000,  # missing topics will block unless we cache cluster metadata and pre-check
                     connections_max_idle_ms=self.config["connections_max_idle_ms"],  # helps through cluster upgrades ??
-                    client_factory=KarapaceKafkaClient,
+                    kafka_client=KarapaceKafkaClient,
                 )
             except:  # pylint: disable=bare-except
                 self.log.exception("Unable to create producer, retrying")
diff --git a/karapace/schema_backup.py b/karapace/schema_backup.py
index e19d6d655..b720e3900 100644
--- a/karapace/schema_backup.py
+++ b/karapace/schema_backup.py
@@ -51,7 +51,7 @@ def init_consumer(self):
             ssl_keyfile=self.config["ssl_keyfile"],
             auto_offset_reset="earliest",
             metadata_max_age_ms=self.config["metadata_max_age_ms"],
-            client_factory=KarapaceKafkaClient,
+            kafka_client=KarapaceKafkaClient,
         )
 
     def init_producer(self):
@@ -61,7 +61,7 @@ def init_producer(self):
             ssl_cafile=self.config["ssl_cafile"],
             ssl_certfile=self.config["ssl_certfile"],
             ssl_keyfile=self.config["ssl_keyfile"],
-            client_factory=KarapaceKafkaClient,
+            kafka_client=KarapaceKafkaClient,
         )
 
     def init_admin_client(self):
@@ -80,7 +80,7 @@ def init_admin_client(self):
                     ssl_cafile=self.config["ssl_cafile"],
                     ssl_certfile=self.config["ssl_certfile"],
                     ssl_keyfile=self.config["ssl_keyfile"],
-                    client_factory=KarapaceKafkaClient,
+                    kafka_client=KarapaceKafkaClient,
                 )
                 break
             except (NodeNotReadyError, NoBrokersAvailable, AssertionError):
diff --git a/karapace/schema_reader.py b/karapace/schema_reader.py
index e86e4e06b..edb4d3762 100644
--- a/karapace/schema_reader.py
+++ b/karapace/schema_reader.py
@@ -128,7 +128,7 @@ def init_consumer(self):
             auto_offset_reset="earliest",
             session_timeout_ms=session_timeout_ms,
             request_timeout_ms=request_timeout_ms,
-            client_factory=KarapaceKafkaClient,
+            kafka_client=KarapaceKafkaClient,
             metadata_max_age_ms=self.config["metadata_max_age_ms"],
         )
 
diff --git a/requirements-dev.txt b/requirements-dev.txt
index 1b15c3ee3..f9df04076 100644
--- a/requirements-dev.txt
+++ b/requirements-dev.txt
@@ -1,5 +1,5 @@
 git+https://github.com/aiven/avro.git@skip-namespace-validation#subdirectory=lang/py3/
-git+git://github.com/aiven/kafka-python.git@39a372538c6bdfbfcb7852c36bed5de61e34bad8
+git+git://github.com/aiven/kafka-python.git@346c01e4eec6bdcccc99ca613b79020f3be35eb7
 yapf==0.30.0
 aiohttp-socks==0.3.4
 pylint==2.4.4