diff --git a/dataflow/snippets/requirements.txt b/dataflow/snippets/requirements.txt
index 0f0d8796fa..844fbdb4d1 100644
--- a/dataflow/snippets/requirements.txt
+++ b/dataflow/snippets/requirements.txt
@@ -1,2 +1,2 @@
 apache-beam[gcp]==2.63.0
-kafka-python==2.0.6
+kafka-python==3.0.0