Skip to content

Commit

Permalink
[SPARK-27973][MINOR] [EXAMPLES]correct DirectKafkaWordCount usage tex…
Browse files Browse the repository at this point in the history
…t 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.zhang@gmail.com>
Signed-off-by: Sean Owen <sean.owen@databricks.com>
  • Loading branch information
cnZach authored and srowen committed Jun 7, 2019
1 parent b30655b commit 5cdc506
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -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
Expand Down

0 comments on commit 5cdc506

Please sign in to comment.