HumanSignal
diff --git a/‎poetry.lock
+10-6 b/‎poetry.lock
+10-6
diff --git a/‎pyproject.toml
+1-1 b/‎pyproject.toml
+1-1
@@ -37,7 +37,7 @@ kombu = ">=5.4.0rc2" # Pin version to fix https://github.com/celery/celery/issue
 uvicorn = "*"
 pydantic-settings = "^2.2.1"
 label-studio-sdk = {url = "https://github.com/HumanSignal/label-studio-sdk/archive/83ec0f8a270e86ceabe8a8b846d404f1113ebd33.zip"}
-kafka-python = "^2.0.2"
+kafka-python-ng = "^2.2.3"
 requests = "^2.32.0"
 litellm = "^1.47.2"
 pandarallel = "^1.6.5"