This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 89ca658 [SPARK-27973][MINOR] [EXAMPLES]correct DirectKafkaWordCount
usage text with groupId
89ca658 is described below
commit 89ca658ef5ad0557763feb2a0917d48aad8728df
Author: Yuexin Zhang <zach.yx.zh...@gmail.com>
AuthorDate: Fri Jun 7 08:02:02 2019 -0500
[SPARK-27973][MINOR] [EXAMPLES]correct DirectKafkaWordCount usage text with
groupId
## What changes were proposed in this pull request?
Usage: DirectKafkaWordCount <brokers> <topics>
--
<brokers> is a list of one or more Kafka brokers
<groupId> is a consumer group name to consume from topics
<topics> is a list of one or more kafka topics to consume from
## How was this patch tested?
N/A.
Please review https://spark.apache.org/contributing.html before opening a
pull request.
Closes #24819 from cnZach/minor_DirectKafkaWordCount_UsageWithGroupId.
Authored-by: Yuexin Zhang <zach.yx.zh...@gmail.com>
Signed-off-by: Sean Owen <sean.o...@databricks.com>
---
.../org/apache/spark/examples/streaming/DirectKafkaWordCount.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala
b/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala
index 2082fb7..3024b59 100644
---
a/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala
+++
b/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala
@@ -40,7 +40,7 @@ object DirectKafkaWordCount {
def main(args: Array[String]) {
if (args.length < 3) {
System.err.println(s"""
- |Usage: DirectKafkaWordCount <brokers> <topics>
+ |Usage: DirectKafkaWordCount <brokers> <groupId> <topics>
| <brokers> is a list of one or more Kafka brokers
| <groupId> is a consumer group name to consume from topics
| <topics> is a list of one or more kafka topics to consume from
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
