Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-27973

Streaming sample DirectKafkaWordCount should mention GroupId in usage

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Trivial
    • Resolution: Fixed
    • 2.4.3
    • 2.4.4, 3.0.0
    • Examples
    • None

    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

          Activity

            People

              yxzhang Yuexin Zhang
              yxzhang Yuexin Zhang
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: