flink消费kafka报错：org.apache.kafka.clients.consumer.KafkaConsumer.assign(Ljava/util/List;)V

flink消费kafka上数据时报错：
Caused by: java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.assign(Ljava/util/List;)V

错误原因：
Flink的kafka Consumer版本和kafka-client的版本不一致

解决方案：三者版本一致

正确配置

pom:
       <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kafka-0.10_2.11</artifactId>
            <version>${flink.version}</version>
        </dependency>
 
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>${kafka.version}</version>
        </dependency>
 
code:
val kafka09 =new  FlinkKafkaConsumer09[String](topics,new SimpleStringSchema(),properties)
//对应的kafka.version=0.9.0.1
 
val kafka010=new  FlinkKafkaConsumer010[String](topics,new SimpleStringSchema(),properties)
//对应的kakfa.version=1.0.0

参考：https://blog.csdn.net/wangyu1025391259/article/details/86627954

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/weixin_43079984/article/details/88826154
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

发表于 2020-03-01 19:46:53
阅读 ( 2682 )
分类：

flink消费kafka报错：org.apache.kafka.clients.consumer.KafkaConsumer.assign(Ljava/util/List;)V

你可能感兴趣的文章

精选的优质文章

0 条评论

官方社群

GO教程

推荐文章

猜你喜欢

随便看看