From 9fbe07d2d09520ea8dcfe1c225df602105d3bb4b Mon Sep 17 00:00:00 2001
From: Mayur Singal <39544459+ulixius9@users.noreply.github.com>
Date: Wed, 22 Jun 2022 01:52:04 +0530
Subject: [PATCH] Fix #5544: Downgrading Kafka Version (#5545)

---
 ingestion/setup.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ingestion/setup.py b/ingestion/setup.py
index 9f0563f9917..1384e8fef2c 100644
--- a/ingestion/setup.py
+++ b/ingestion/setup.py
@@ -95,7 +95,7 @@ plugins: Dict[str, Set[str]] = {
         "presto-types-parser==0.0.2",
     },
     "kafka": {
-        "confluent_kafka>=1.5.0",
+        "confluent_kafka==1.8.2",
         "fastavro>=1.2.0",
         "avro-python3",
         "confluent_avro",