Skip to content

Commit fc17f1a

Browse files
mgorbovrsotn-mapr
authored andcommitted
fixed syntax error in V09DirectKafkaWordCount example (apache#75)
Signed-off-by: Rostyslav Sotnychenko <rsotnychenko@maprtech.com>
1 parent c7de39f commit fc17f1a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

examples/src/main/scala/org/apache/spark/examples/streaming/V09DirectKafkaWordCount.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ object V09DirectKafkaWordCount {
9090

9191
val consumerStrategy = ConsumerStrategies.Subscribe[String, String](topicsSet, kafkaParams)
9292
val messages = KafkaUtils.createDirectStream[String, String](
93-
ssc, LocationStrategies.PreferConsistent(), consumerStrategy)
93+
ssc, LocationStrategies.PreferConsistent, consumerStrategy)
9494

9595
// Get the lines, split them into words, count the words and print
9696
val lines = messages.map(_.value())

0 commit comments

Comments
 (0)