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

Add a class in spark with all Kafka configuration key available as string

    XMLWordPrintableJSON

Details

    Description

      Add a class in spark with all Kafka configuration key available as string.

      see the highligted class which i want.

      eg:-

      Current code:-

      val df_cluster1 = spark
      .read
      .format("kafka")
      .option("kafka.bootstrap.servers","cluster1_host:cluster1_port)
      .option("subscribe", "topic1")

      Expected code:-

      val df_cluster1 = spark
      .read
      .format("kafka")
      .option(KafkaConstantClass.KAFKA_BOOTSTRAP_SERVERS,"cluster1_host:cluster1_port)
      .option(KafkaConstantClass.subscribe, "topic1")

      Attachments

        Activity

          People

            Unassigned Unassigned
            gunjan075 Gunjan Kumar
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: