kafka 与spark集成 序列化问题
sparkConf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
sparkConf.registerKryoClasses(Array(
classOf[Array[org.apache.kafka.clients.consumer.ConsumerRecord[String,String]]]
))java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord
原文：https://www.cnblogs.com/hejunhong/p/12080891.html