[ https://issues.apache.org/jira/browse/SPARK-27973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sean Owen resolved SPARK-27973. ------------------------------- Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24819 [https://github.com/apache/spark/pull/24819] > 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 > Assignee: Yuexin Zhang > Priority: Trivial > Fix For: 3.0.0 > > > 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