diff --git a/README.md b/README.md
index fa4c2f9..d322d19 100644
--- a/README.md
+++ b/README.md
@@ -73,7 +73,7 @@
 
 ```
 $ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.KafkaWordCount \
-    -Dexec.args="--runner=SamzaRunner" -P samza-runner
+    -Dexec.args="--runner=SamzaRunner --experiments=use_deprecated_read" -P samza-runner
 ```
 
 #### Packaging Your Application
diff --git a/pom.xml b/pom.xml
index 2689de3..6364f4f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,8 +27,8 @@
   <packaging>jar</packaging>
 
   <properties>
-    <beam.version>2.11.0</beam.version>
-    <samza.version>0.14.1</samza.version>
+    <beam.version>2.27.0</beam.version>
+    <samza.version>1.3.0</samza.version>
 
     <guava.version>20.0</guava.version>
     <hamcrest.version>1.3</hamcrest.version>
@@ -182,7 +182,7 @@
 
     <dependency>
       <groupId>org.apache.samza</groupId>
-      <artifactId>samza-log4j</artifactId>
+      <artifactId>samza-log4j_2.11</artifactId>
       <version>${samza.version}</version>
     </dependency>
 
@@ -210,6 +210,12 @@
       <version>${samza.version}</version>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.kafka</groupId>
+      <artifactId>kafka-clients</artifactId>
+      <version>2.0.1</version>
+    </dependency>
+
     <!-- Dependencies below this line are specific dependencies needed by the examples code. -->
     <dependency>
       <groupId>joda-time</groupId>
diff --git a/src/main/bash/run-beam-container.sh b/src/main/bash/run-beam-container.sh
index 4e9f8d9..0c70f38 100755
--- a/src/main/bash/run-beam-container.sh
+++ b/src/main/bash/run-beam-container.sh
@@ -33,4 +33,4 @@
 
 override="{\"task.execute\":\"bin/run-beam-container.sh $@\"}"
 
-exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configFactory=org.apache.beam.runners.samza.container.ContainerCfgFactory --configOverride="$override" "${@:2}"
\ No newline at end of file
+exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configFactory=org.apache.beam.runners.samza.container.ContainerCfgFactory --configOverride="$override" --samzaExecutionEnvironment=YARN --experiments=use_deprecated_read "${@:2}"
\ No newline at end of file
diff --git a/src/main/bash/run-beam-standalone.sh b/src/main/bash/run-beam-standalone.sh
index 88bd43c..47b00bb 100755
--- a/src/main/bash/run-beam-standalone.sh
+++ b/src/main/bash/run-beam-standalone.sh
@@ -20,4 +20,4 @@
 
 override="{\"task.execute\":\"bin/run-beam-container.sh $@\"}"
 
-exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" "${@:2}"
\ No newline at end of file
+exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" --experiments=use_deprecated_read "${@:2}"
\ No newline at end of file
diff --git a/src/main/bash/run-beam-yarn.sh b/src/main/bash/run-beam-yarn.sh
index 0e1df52..e467ebe 100755
--- a/src/main/bash/run-beam-yarn.sh
+++ b/src/main/bash/run-beam-yarn.sh
@@ -33,7 +33,7 @@
 
 case $op in
   run)
-    exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" "${@:2}"
+    exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" --samzaExecutionEnvironment=YARN --experiments=use_deprecated_read "${@:2}"
   ;;
 
   kill)