diff --git a/streaming/pom.xml b/streaming/pom.xml
index 7bea069b6158a2292c47bd6f6c91bead6e9fd3f9..c793f207c6d302124a099758a305466cff26f803 100644
--- a/streaming/pom.xml
+++ b/streaming/pom.xml
@@ -109,6 +109,11 @@
       <artifactId>slf4j-log4j12</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.eclipse.paho</groupId>
+      <artifactId>mqtt-client</artifactId>
+       <version>0.4.0</version>
+    </dependency>
   </dependencies>
   <build>
     <outputDirectory>target/scala-${scala.version}/classes</outputDirectory>