From 7be37c138a3ff2c19d3ab3154994e8272cab3a08 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Maciej=20Bry=C5=84ski?= <maciek-github@brynski.pl>
Date: Mon, 6 Jan 2025 18:01:22 +0100
Subject: [PATCH] Fixes 19217: Add ability to use confluent-kafka version
 greater than 2.1.1 (#19218)

* Add ability to use confluent-kafka version greater than 2.1.1

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

diff --git a/ingestion/setup.py b/ingestion/setup.py
index b117351d6a0..42b5c4e3bc9 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",
         "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