dataartisans / kafka-example Goto Github PK

Hi
After importing this project into eclipse IDE and after compiling the source, ended up with following errors. I thought adding the reference plugin into pom.xml would solve this. However, the file ReadFromKafka itself highlighting some errors saying that "The import.org.apache cannot be resolved". Please help.
Description Resource Path Location Type
DataStream cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 52 Java Problem
FlinkKafkaConsumer082 cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 52 Java Problem
MapFunction cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 57 Java Problem
ParameterTool cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 50 Java Problem
ParameterTool cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 50 Java Problem
SimpleStringSchema cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 52 Java Problem
StreamExecutionEnvironment cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 47 Java Problem
StreamExecutionEnvironment cannot be resolved to a type ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 47 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 20 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 21 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 22 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 23 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 24 Java Problem
The import org.apache cannot be resolved ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 25 Java Problem
The method map(String) of type new MapFunction<String,String>(){} must override or implement a supertype method ReadFromKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 61 Java Problem
DataStream cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 52 Java Problem
DeserializationSchema cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 81 Java Problem
KafkaSink cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 55 Java Problem
ParameterTool cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 49 Java Problem
ParameterTool cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 49 Java Problem
SerializationSchema cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 81 Java Problem
SourceContext cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 67 Java Problem
SourceFunction cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 62 Java Problem
StreamExecutionEnvironment cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 46 Java Problem
StreamExecutionEnvironment cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 46 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 20 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 21 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 22 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 23 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 24 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 25 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 26 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 27 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 28 Java Problem
The import org.apache cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 29 Java Problem
The method cancel() of type WriteIntoKafka.SimpleStringGenerator must override or implement a supertype method WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 75 Java Problem
TypeExtractor cannot be resolved WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 100 Java Problem
TypeInformation cannot be resolved to a type WriteIntoKafka.java /kafka-connect-flink/src/main/java/com/dataartisans line 99 Java Problem