kafka 与spark集成 序列化问题
sparkConf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")sparkConf.registerKryoClasses(Array( classOf[Array[org.apache.kafka.clients.consumer.ConsumerRecord[String,String]]] ))