spark-streaming- все статьи тега

Как преобразовать байты из Кафки в их исходный объект?

Я извлекаю данные из Kafka, а затем десериализую Array[Byte], используя декодер по умолчанию, и после этого мои элементы RDD выглядят следующим образом (null,[B@406fa9b2), (null,[B@21a9fe0) но мне нужны мои исходные данные, которые имеют схему, так как я могу этого достичь? Я сериализирую сообщения в формате Avro. ...