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

kafka 与spark集成序列化问题

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

相关文章：

2021-05-21
2022-02-18
2021-08-07
2022-12-23
2021-07-09
2022-01-14

猜你喜欢

2022-12-23
2021-09-03
2022-12-23
2021-05-24
2021-09-28

相关资源

相似解决方案

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode