Description
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>
Attachments
Issue Links
- links to