in 0.8 you can set the property "auto.offset.reset" = "smallest" when creating your ConsumerConfig ... this will override the default value of "largest"
take a look at ConsoleConsumer.scala for more example if need be /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly <http://www.stealth.ly> Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/ On Thu, Jul 25, 2013 at 1:24 PM, James A. Robinson < j...@highwire.stanford.edu> wrote: > On Thu, Jul 25, 2013 at 9:11 AM, Withers, Robert > <robert.with...@dish.com> wrote: > > We are creating a consumer with properties and I did not see a > > property that screamed that it was to start at the beginning of a > > topic. Is there such a property? > > In v0.7, set 'autooffset.reset' to 'smallest'. > > Jim > > - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - > James A. Robinson j...@highwire.stanford.edu > HighWire | Stanford University http://highwire.stanford.edu/ > +1 650 7237294 (Work) +1 650 7259335 (Fax) >
