На данный момент я создаю обобщенную запись avro из фрейма данных spark с помощью файла file.avsc и класса POJO avro (сгенерированного avro).
Попытка добиться создания универсальной записи avro без класса avro в производителе scala kafka во время выполнения путем ввода имени класса в переменную независимо от количества полей и его типа данных.
ТеперьЯ смотрю в скала отражение для его реализации. Пожалуйста, предложите, если какой-либо код или API доступны для его достижения.