From babdcad1cc64d34629bcebdc89c10da6dc5c5bc6 Mon Sep 17 00:00:00 2001
From: Anton Kuraev <anton.kuraev@acryl.io>
Date: Wed, 18 Dec 2024 13:13:13 -0800
Subject: [PATCH] Add explicit dependency on confluent_kafka

---
 datahub-actions/setup.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/datahub-actions/setup.py b/datahub-actions/setup.py
index 534873f..04f63b1 100644
--- a/datahub-actions/setup.py
+++ b/datahub-actions/setup.py
@@ -67,7 +67,9 @@ def get_long_description():
 # Note: for all of these, framework_common will be added.
 plugins: Dict[str, Set[str]] = {
     # Source Plugins
-    "kafka": set(),  # included by default
+    "kafka": {
+        "confluent_kafka>=2.6.1",
+    },
     # Action Plugins
     "executor": {
         "acryl-executor==0.1.2",