diff --git a/spark_23/src/main/scala/com/vishnuviswanath/spark/streaming/KafkaSourceStreaming.scala b/spark_23/src/main/scala/com/vishnuviswanath/spark/streaming/KafkaSourceStreaming.scala index 4101e13..5e583d4 100644 --- a/spark_23/src/main/scala/com/vishnuviswanath/spark/streaming/KafkaSourceStreaming.scala +++ b/spark_23/src/main/scala/com/vishnuviswanath/spark/streaming/KafkaSourceStreaming.scala @@ -15,7 +15,7 @@ import org.apache.spark.sql.functions._ * Download from https://kafka.apache.org/downloads * * start zookeeper: - * bin/zookeeper-server-start.sh conig/zookeeper.properties + * bin/zookeeper-server-start.sh config/zookeeper.properties * * start kafka broker(s): * bin/kafka-server-start.sh config/server.properties