spark streaming 和 kafka ,打成jar包后((相关第三方依赖也在里面)),放到集群上总是报StringDecoder 找不到class,但我确定是存在的,就算换成另一种--jars提交了相关kafka的依赖包,spark-submit执行后不是TopicMetadataRequest类找不到就是StringDecoder找不到,kafka是0.8.2.1,spark'是1.6.0-cdh5.8.0的,大家遇到过这种问题吗
我的问题和你的差不多,import kafka.serializer.StringDecoder直接就是不能导入,serializer标红,然后用尽了各种办法就是不能导入这个包,楼主怎么看
赞0
踩0