Hi Gwen,
I have changed the java code kafkawordcount to use reducebykeyandwindow in
spark.
- Messaggio originale -
Da: "Gwen Shapira"
Inviato: 03/11/2014 21:08
A: "us...@kafka.apache.org"
Cc: "u...@spark.incubator.apache.org"
Oggetto: Re: Spark Kafka P
Hi Guys,
Anyone could explain me how to work Kafka with Spark, I am using the
JavaKafkaWordCount.java like a test and the line command is:
./run-example org.apache.spark.streaming.examples.JavaKafkaWordCount
spark://192.168.0.13:7077 computer49:2181 test-consumer-group unibs.it 3
and like a pro
