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",