Update comment in kafka producer

akshitvjain · May 7, 2020 · a0577f4 · a0577f4
1 parent 818ceb6
commit a0577f4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/streaming/KafkaSparkProcessor.scala b/src/main/scala/org/streaming/KafkaSparkProcessor.scala
@@ -67,7 +67,7 @@ object KafkaSparkProcessor {
     // Pass kafka topic name
     val Array(topics) = args
 
-    // Set the Spark StreamingContext to create a DStream for every 30 seconds
+    // Set the Spark StreamingContext to create a DStream for every 15 seconds
     val ssc = new StreamingContext(sc, Seconds(15))
     ssc.checkpoint("checkpoint")