Re: java.lang.NoClassDefFoundError --- FlinkKafkaConsumer

2019-06-13 Thread Yun Tang
#appendix-template-for-building-a-jar-with-dependencies Best Yun Tang From: syed Sent: Thursday, June 13, 2019 16:28 To: user@flink.apache.org Subject: java.lang.NoClassDefFoundError --- FlinkKafkaConsumer hi I am trying to add a kafka source to the standard WordCount

java.lang.NoClassDefFoundError --- FlinkKafkaConsumer

2019-06-13 Thread syed
hi I am trying to add a kafka source to the standard WordCount application available with flink, So that the application may count words from the kafka source. I added the source like this *DataStream text; if(params.has("topic")&¶ms.has("bootstrap.servers")&¶ms.has("zookeeper.connect") &¶ms.ha