如何通过spark结构流在Kafka中以编程方式创建主题

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.streaming.Trigger

val spark = SparkSession.builder
  .appName("KafkaTopicCreation")
  .master("local[*]")
  .getOrCreate()

val kafkaBootstrapServers = "kafka_server:9092"
val kafkaTopic = "your_topic_name"

val emptyDataFrame = spark.emptyDataFrame

emptyDataFrame
  .writeStream
  .format("kafka")
  .option("kafka.bootstrap.servers", kafkaBootstrapServers)
  .option("topic", kafkaTopic)
  .option("checkpointLocation", "/path/to/checkpoint")
  .trigger(Trigger.ProcessingTime("10 seconds"))
  .start()
  .awaitTermination()