[jira] [Updated] (SPARK-24743) Update the JavaDirectKafkaWordCount example to support the new API of Kafka

2018-07-05 Thread luochuan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luochuan updated SPARK-24743: - Summary: Update the JavaDirectKafkaWordCount example to support the new API of Kafka (was: Update the

[jira] [Updated] (SPARK-24743) Update the DirectKafkaWordCount example to support the new API of Kafka

2018-07-05 Thread luochuan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luochuan updated SPARK-24743: - Description: when I ran the example JavaDirectKafkaWordCount as follows: ./bin/spark-submit --class

[jira] [Created] (SPARK-24743) Update the DirectKafkaWordCount example to support the new API of Kafka

2018-07-05 Thread luochuan (JIRA)
luochuan created SPARK-24743: Summary: Update the DirectKafkaWordCount example to support the new API of Kafka Key: SPARK-24743 URL: https://issues.apache.org/jira/browse/SPARK-24743 Project: Spark