diff --git a/pyproject.toml b/pyproject.toml
index b6ff05a..fc47821 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -44,7 +44,7 @@ dependencies = [
     "google-auth-oauthlib>=0.4.6",
     "google-auth>=2.3.3",
     "imapclient>=2.1.0",
-    "kafka-python>=1.4.4",
+    "kafka-python-ng>=2.2.2",
     "lxml>=4.4.0",
     "mailsuite>=1.6.1",
     "msgraph-core==0.2.2",
diff --git a/requirements.txt b/requirements.txt
index aaf360d..5733843 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -12,7 +12,7 @@ dateparser>=1.1.1
 elasticsearch<7.14.0
 elasticsearch-dsl>=7.4.0
 opensearch-py>=2.4.2,<=3.0.0
-kafka-python>=1.4.4
+kafka-python-ng>=2.2.2
 mailsuite>=1.6.1
 nose>=1.3.7
 wheel>=0.37.0