Como implementar a desserialização no consumidor kafka usando o scala?
Eu tenho a seguinte linha no código do meu consumidor kafka.
val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicpMap).map(_._2)
Como desserializar "linhas" desse fluxo no objeto original? A serialisabilidade foi implementada no produtor kafka, estendendo a classe para serialisable. Estou implementando isso no spark usando scala.