Spark Streaming получает байт [] от Кафки - PullRequest
0 голосов
/ 22 февраля 2019

Я хочу интегрировать 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]);
...