[SPARK-31961] Add a class in spark with all Kafka configuration key available as string

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Won't Fix
• Affects Version/s: 2.4.6
• Component/s: SQL, Structured Streaming
• Labels: kafka sql structured-streaming
• Assignee: Unassigned
• Reporter: Gunjan Kumar
• Created: 10/Jun/20 20:41
• Updated: 12/Jun/20 04:08
• Resolved: 12/Jun/20 04:08

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")