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
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
kafka提交异常org.apache.kafka.clients.consumer.CommitFailedException
java.io.NotSerializableException 没有序列化异常
java.io.NotSerializableException错误解决方法
CDH下集成spark2.2.0与kafka（四十一）：在spark+kafka流处理程序中抛出错误java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/util/Collection;)V
报错：Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[Kafka] - Kafka Java Consumer实现(二)
org.apache.hadoop.ipc.RemoteException(java.io.IOException)
java.lang.ClassCastException: org.apache.hadoop.io.Text cannot be cast to org.apache.h...
Kafka设计解析（二十）Apache Flink Kafka consumer
NoClassDefFoundError: org/apache/kafka/common/requests/IsolationLevel at org.apache.kafka.streams.StreamsConfig.(StreamsConfig.java:521)