diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
index f40caad322f5957e2ad0d5257b180170450c1941..85b9a54b40bafb2b2dc4b0595335dc30431dbce1 100644
--- a/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
@@ -56,7 +56,7 @@ object MQTTPublisher {
       while (true) {
         try {
           msgtopic.publish(message)
-          println(s"Published data. topic: {msgtopic.getName()}; Message: {message}")
+          println(s"Published data. topic: ${msgtopic.getName()}; Message: $message")
         } catch {
           case e: MqttException if e.getReasonCode == MqttException.REASON_CODE_MAX_INFLIGHT =>
             Thread.sleep(10)