flume kafka sparkstreaming整合后集群报错org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/uti

简介      整个项目架构是在CDH中,flume采集数据到kafka,而后sparkstreaming消费(flume1.7版本,kafka0.10版本,spark 2.1版本)。原本local本地模式测试已经没有问题,可是部署到集群上就报错以下: Exception in thread "streaming-start" java.lang.NoSuchMethodError: org.ap
相关文章
相关标签/搜索