diff --git a/build.sbt b/build.sbt
index b952f69..b76fa54 100644
--- a/build.sbt
+++ b/build.sbt
@@ -2,7 +2,7 @@ import sbt._
 import Keys._
 
 val scioVersion = "0.11.1"
-val beamVersion = "2.19.0"
+val beamVersion = "2.34.0"
 val scalaMacrosVersion = "2.1.1"
 val slf4jVersion = "1.7.29"
 val scalatestVersion = "3.1.0"
@@ -63,7 +63,7 @@ lazy val root: Project = project
     libraryDependencies ++= Seq(
       "com.spotify" %% "scio-core" % scioVersion,
       "com.spotify" %% "scio-test" % scioVersion % Test,
-      "org.apache.beam" % "beam-runners-google-cloud-dataflow-java" % beamVersion,
+      ("org.apache.beam" % "beam-runners-google-cloud-dataflow-java" % beamVersion) exclude("org.apache.beam", "beam-sdks-java-io-kafka"),
       "io.circe" %% "circe-parser" % circe,
       "com.snowplowanalytics" %% "iglu-core-circe" % igluCore,
       "org.slf4j" % "slf4j-simple" % slf4jVersion,