Hi Guys,
I am doing some tests with JavaKafkaWordCount, my cluster is composed by 8
workers and 1 driver con spark-1.1.0, I am using Kafka too and I have some
questions about.
1 - When I launch the command:
bin/spark-submit --class org.apache.spark.examples.streaming.JavaKafkaWordCount
.
Here's the code:
public static void main(String[] args) {
if (args.length 4) {
System.err.println(Usage: JavaKafkaWordCount zkQuorum
group topics numThreads);
System.exit(1);
}
//StreamingExamples.setStreamingLogLevels();
//SparkConf
) {
System.err.println(Usage: JavaKafkaWordCount zkQuorum group
topics numThreads);
System.exit(1);
}
//StreamingExamples.setStreamingLogLevels();
//SparkConf sparkConf = new
SparkConf().setAppName(JavaKafkaWordCount);
// Location of the Spark
in both 'Spark' as well as 'Kafka'.
Please help. Thanks.
Here's the code:
public static void main(String[] args) {
if (args.length 4) {
System.err.println(Usage: JavaKafkaWordCount zkQuorum
group
topics numThreads);
System.exit(1
