Как читать данные из раздела кафки с другой схемой (имеет некоторые дополнительные объекты) в структурированной потоковой передаче

#scala #apache-spark #apache-kafka #jsonschema #spark-structured-streaming Вопрос: у меня есть данные , поступающие в тему кафки, в которой есть необязательный объект, и, поскольку он необязателен, мне не хватает этих записей при…

Продолжить чтениеКак читать данные из раздела кафки с другой схемой (имеет некоторые дополнительные объекты) в структурированной потоковой передаче