You can use .option( "auto.offset.reset","earliest") while reading from kafka. With this, new stream will read from the first offset present for topic .
On Wed, May 23, 2018 at 11:32 AM, karthikjay <aswin8...@gmail.com> wrote: > Chris, > > Thank you for responding. I get it. > > But, if I am using a console sink without checkpoint location, I do not see > any messages in the console in IntellijIDEA IDE. I do not explicitly > specify > checkpointLocation in this case. How do I clear the working directory data > and force Spark to read Kafka messages from the beginning. ? > > > > -- > Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ > > --------------------------------------------------------------------- > To unsubscribe e-mail: user-unsubscr...@spark.apache.org > >
