Description
when I ran the example JavaDirectKafkaWordCount as follows:
./bin/spark-submit --class org.apache.spark.examples.streaming.JavaDirectKafkaWordCount --master local --jars /somepath/spark-streaming-kafka-0-10-assembly_2.11-2.3.1.jar examples/jars/spark-examples_2.11-2.3.1.jar kafka-broker:port topic
Then a error happened: 'org.apache.kafka.common.config.ConfigException:Missing required configuration "bootstrap.servers" which has no default value'. So I looked into the code and found the example JavaDirectKafkaWordCount misses some kafka required configs.