如何在Pyspark中获取kafka模式注册表？

from pyspark.sql import SparkSession
from pyspark.sql.functions import from_json
from pyspark.sql.types import StructType

spark = SparkSession.builder \
    .appName("KafkaSchemaRegistryExample") \
    .getOrCreate()

kafka_bootstrap_servers = "kafka服务器地址:9092"
kafka_topic = "kafka主题名称"
schema_registry_url = "模式注册表URL"
schema_registry_subject = "模式注册表主题名称"

df = spark \
    .readStream \
    .format("kafka") \
    .option("kafka.bootstrap.servers", kafka_bootstrap_servers) \
    .option("subscribe", kafka_topic) \
    .load()

# 解析模式
schema = spark \
    .read \
    .format("io.confluent.kafka.schemaregistry.spark.SparkAvroConfluentSchemaRegistry") \
    .option("url", schema_registry_url) \
    .option("subject", schema_registry_subject) \
    .load() \
    .select("value")

# 将数据应用模式
df = df.select(from_json(df.value.cast("string"), schema).alias("data")).select("data.*")