[HOTFIX] Fix MQTT test case configuration
diff --git a/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala b/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala
index 257bd0b..4c1c75f 100644
--- a/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala
+++ b/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala
@@ -161,7 +161,7 @@
// previously running stream left off.
val provider = new MQTTStreamSourceProvider
val parameters = Map("brokerUrl" -> ("tcp://" + mqttTestUtils.brokerUri), "topic" -> "test",
- "localStorage" -> tmpDir, "clientId" -> "clientId")
+ "localStorage" -> tmpDir, "clientId" -> "clientId", "QoS" -> "2")
val offset: Long = provider.createSource(sqlContext, "", None, "", parameters)
.getOffset.get.asInstanceOf[LongOffset].offset
assert(offset == 100L)
