[ https://issues.apache.org/jira/browse/SPARK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16533403#comment-16533403 ]
Apache Spark commented on SPARK-24743: -------------------------------------- User 'cluo512' has created a pull request for this issue: https://github.com/apache/spark/pull/21717 > Update the JavaDirectKafkaWordCount example to support the new API of Kafka > --------------------------------------------------------------------------- > > Key: SPARK-24743 > URL: https://issues.apache.org/jira/browse/SPARK-24743 > Project: Spark > Issue Type: Bug > Components: Examples > Affects Versions: 2.3.1 > Reporter: luochuan > Priority: Major > > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org