Я пытаюсь преобразовать DStream [Array [Byte]] в DStream [String], но получаю сообщение об ошибке: [B нельзя привести к [Ljava.lang.Byte со следующим кодом.
val data = KafkaUtils.CreateDirectStream(ssc,kafkaConf,Map(topic,1).map(bytes => bytes._2.toString)
data имеет тип DStream [String], но выдает ошибку выше при выполнении кода.
Может ли кто-нибудь помочь мне в том, как преобразовать DStream [Array [Byte]] в DStream [String]
Я пробовал пару вещей, таких как преобразование байтов => новой строки (байтов), но там говорится, что строка не является допустимым конструктором.
Спасибо