Я читаю из потоковых данных (значения, разделенные запятыми), используя KafkaUtils.createDirectStream. Я хочу преобразовать сообщения в фрейм данных (набор данных) с помощью схемы (StructType). Я пишу это на Java. Пожалуйста, предложите шаги, которые мне нужно выполнить.