diff --git a/ingestion/setup.py b/ingestion/setup.py
index 7e8b015d657..51a48a55666 100644
--- a/ingestion/setup.py
+++ b/ingestion/setup.py
@@ -76,7 +76,7 @@ COMMONS = {
     },
     "kafka": {
         VERSIONS["avro"],
-        "confluent_kafka>=2.1.1",
+        "confluent_kafka>=2.1.1,<=2.6.1",
         "fastavro>=1.2.0",
         # Due to https://github.com/grpc/grpc/issues/30843#issuecomment-1303816925
         # use >= v1.47.2 https://github.com/grpc/grpc/blob/v1.47.2/tools/distrib/python/grpcio_tools/grpc_version.py#L17