diff --git a/pyproject.toml b/pyproject.toml
index 9977915..aed3426 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -29,6 +29,7 @@ requires-python = ">=3.12"
 # Make sure to list one dependency per line.
 dependencies = [
   "kafka-python",
+  "confluent_kafka",
   "ess-streaming-data-types",
   "requests",
   "rich"
diff --git a/requirements/base.in b/requirements/base.in
index bc1b660..b18da2b 100644
--- a/requirements/base.in
+++ b/requirements/base.in
@@ -3,6 +3,7 @@
 # --- END OF CUSTOM SECTION ---
 # The following was generated by 'tox -e deps', DO NOT EDIT MANUALLY!
 kafka-python
+confluent_kafka
 ess-streaming-data-types
 requests
 rich
diff --git a/requirements/base.txt b/requirements/base.txt
index c2ff2bb..e072a4b 100644
--- a/requirements/base.txt
+++ b/requirements/base.txt
@@ -1,4 +1,4 @@
-# SHA1:fa65536d18d20d383817bc534417d6c283696d35
+# SHA1:bad3be485e41242eafd3a41c6ed2b021210bd026
 #
 # This file is autogenerated by pip-compile-multi
 # To update, run:
@@ -9,6 +9,8 @@ certifi==2024.2.2
     # via requests
 charset-normalizer==3.3.2
     # via requests
+confluent-kafka==2.3.0
+    # via -r base.in
 ess-streaming-data-types==0.23.1
     # via -r base.in
 flatbuffers==24.3.25
diff --git a/requirements/nightly.in b/requirements/nightly.in
index 4122a02..6a10cbf 100644
--- a/requirements/nightly.in
+++ b/requirements/nightly.in
@@ -2,6 +2,7 @@
 # --- END OF CUSTOM SECTION ---
 # The following was generated by 'tox -e deps', DO NOT EDIT MANUALLY!
 kafka-python
+confluent_kafka
 ess-streaming-data-types
 requests
 rich
diff --git a/requirements/nightly.txt b/requirements/nightly.txt
index 32aae2b..4048d6b 100644
--- a/requirements/nightly.txt
+++ b/requirements/nightly.txt
@@ -1,4 +1,4 @@
-# SHA1:d406a5108f5dcf73c54cbfc7b5a3bcdc3e2872fd
+# SHA1:d6bc96251e6b13b5797a6bae33485ff077b19b5f
 #
 # This file is autogenerated by pip-compile-multi
 # To update, run:
@@ -10,6 +10,8 @@ certifi==2024.2.2
     # via requests
 charset-normalizer==3.3.2
     # via requests
+confluent-kafka==2.3.0
+    # via -r nightly.in
 ess-streaming-data-types==0.23.1
     # via -r nightly.in
 flatbuffers==24.3.25