I am not able to compile a program myconsumer.java which uses the following classes from kafka import kafka.consumer.Consumer; import kafka.consumer.ConsumerConfig; import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; import org.apache.spark.sql.DataFrame; import org.apache.spark.sql.SQLContext; It gives errors " cannot load or not found " is there way to resolve this . I have already tried including classpath or using javac -classpath <> myconsumer.java with no success REgards SReeni
@Sreenivas Adiki you need to modify your pom.xm! File and add dependencies for Kafka and spark based on the versions of your cluster. Please look in our documentation for the right repositories.