Как реализовать десериализацию в кафке потребителя с помощью scala?
У меня есть следующая строка в моем коде потребителя kafka.
val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicpMap).map(_._2)
Как десериализовать этот поток «линий» в оригинальный объект? Сериализуемость была реализована в производителе кафки путем расширения класса до сериализуемого. Я реализую это в искре, используя Scala.