Как мы структурируем JSON для нескольких разделов в структурированной потоковой передаче Spark. Приведенный ниже пример, который я вставил сюда только для одного раздела. Ценю вашу помощь.
spark.readStream().format("kafka")
.option("kafka.bootstrap.servers", "****")
.option("subscribePattern", "****.*")
.option("startingOffsets", "{\"Topic01\": {\"0\":250, \"1\": -1}}").load();