Hi,
I have written a code for kafka producer and consumer in scala. I build a jar out of it and try’d to run it in cluster. but it is not running. always stuck with this:
--------------Producer------------------------------------
scala -cp sparklearnings-1.0-SNAPSHOT-jar-with-dependencies.jar org.hadooplearnings.ScalaProducerExample 10000 kafkatestpgm ip-172-31-29-153.ec2.internal:6667
log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.producer.ProducerConfig).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
-------------------------------consumer-------------------------------------
scala -cp sparklearnings-1.0-SNAPSHOT-jar-with-dependencies.jar org.hadooplearnings.ScalaConsumerExample ip-172-31-53-48.ec2.internal:9092 group1 kafkatestpgm
log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.consumer.ConsumerConfig).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
