Yuexin Zhang created SPARK-27973:
------------------------------------
Summary: Streaming sample DirectKafkaWordCount should mention
GroupId in usage
Key: SPARK-27973
URL: https://issues.apache.org/jira/browse/SPARK-27973
Project: Spark
Issue Type: Improvement
Components: Examples
Affects Versions: 2.4.3
Reporter: Yuexin Zhang
The DirectKafkaWordCount sample has been updated to take Consumer Group Id as
one of the input arguments, but we missed it in the sample usage:
System.err.println(s"""
|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
|
""".stripMargin)
Usage should be : DirectKafkaWordCount <brokers> <groupId> <topics>
--
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
