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

KafkaRDD should always set kafka clientId.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Trivial
    • Resolution: Fixed
    • 2.0.2
    • 2.4.0
    • DStreams
    • None

    Description

      I found KafkaRDD not set kafka client.id in "fetchBatch" method (FetchRequestBuilder will set clientId to empty by default), normally this will affect nothing, but in our case ,we use clientId at kafka server side, so we have to rebuild spark-streaming-kafka。

      Attachments

        Activity

          People

            liuzhaokun liuzhaokun
            dixingxing@yeah.net Xingxing Di
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: