碼上快樂

相關內容    簡體    繁體

java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord

本文轉載自   查看原文   2019-12-22 20:21   923    錯誤、異常

kafka 與spark集成 序列化問題

sparkConf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
sparkConf.registerKryoClasses(Array(
 classOf[Array[org.apache.kafka.clients.consumer.ConsumerRecord[String,String]]]
 ))


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 object not serializable (class: org.apache.kafka.clients.consumer.ConsumerRecord) java.io.NotSerializableException java.io.NotSerializableException:異常 spark error Caused by: java.io.NotSerializableException: org.apache.hadoop.hdfs.DistributedFileSystem spark 報錯 Caused by: java.io.NotSerializableException: org.apache.log4j.Logger storm java.io.NotSerializableException kafka提交異常org.apache.kafka.clients.consumer.CommitFailedException java.io.notserializableexception序列化錯誤 java.io.NotSerializableException 沒有序列化異常 java.io.NotSerializableException錯誤解決方法
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM