Я хочу интегрировать Apache Kafka и Spark Streaming, я использую spark-streaming-kafka-0-8_2.11, я обнаружил, что эта функция показана ниже, но типом значения в Kafka является байтовый массив.Как я могу получить байтовый массив от Кафки, используя эту функцию?
import org.apache.spark.streaming.kafka.*;
JavaPairInputDStream<String, String> directKafkaStream =
KafkaUtils.createDirectStream(streamingContext,
[key class], [value class], [key decoder class], [value decoder class],
[map of Kafka parameters], [set of topics to consume]);