Пожалуйста, проголосуйте и примите ответ, если он решит вашу проблему.

я есть код для преобразования моей записи Avro в строку с помощью функцииavroToRowConverter() directKafkaStream.foreachRDD(rdd -> { JavaRDD<Row> newRDD= rdd.map(x->{ Injection<GenericRecord, byte[]> recordInjection ...