Cómo convertir el registro genérico avro anidado a fila

Tengo un código para convertir mi registro avro a Row usando la funciónavroToRowConverter() directKafkaStream.foreachRDD(rdd -> { JavaRDD<Row> newRDD= rdd.map(x->{ Injection<GenericRecord, byte[]> recordInjection ...