开发者社区> 问答> 正文

spark streaming 和 kafka ,打成jar包后((相关第三方依赖也在里面)),放到集群上总是报StringDecoder 找不到class,但我确定是存在的,就算换成另一种--jars提交了相关kafka的依赖包,spark-submit执行后不是TopicMetadataRequest类找不到就是StringDecoder找不到,kafka是0.8.2.1,spark'是1.6.0-cdh5.8.0的,大家遇到过这种问题吗

社区小助手 2019-01-30 15:34:40 677

spark streaming 和 kafka ,打成jar包后((相关第三方依赖也在里面)),放到集群上总是报StringDecoder 找不到class,但我确定是存在的,就算换成另一种--jars提交了相关kafka的依赖包,spark-submit执行后不是TopicMetadataRequest类找不到就是StringDecoder找不到,kafka是0.8.2.1,spark'是1.6.0-cdh5.8.0的,大家遇到过这种问题吗

消息中间件 分布式计算 Java Kafka Spark 流计算
分享到
取消 提交回答
全部回答(2)
  • 游客frilnf57c73ia
    2019-07-17 23:27:21

    我的问题和你的差不多,import kafka.serializer.StringDecoder直接就是不能导入,serializer标红,然后用尽了各种办法就是不能导入这个包,楼主怎么看

    0 0
  • 1426694731350515
    2019-07-17 23:27:21

    路过

    0 0
添加回答
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题