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

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

              Dates

              • Created:
                Updated:
                Resolved: