Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Re: how to force a consumer to start at the beginning


Copy link to this message
-
Re: how to force a consumer to start at the beginning
Joe Stein 2013-07-25, 17:42
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 <
[EMAIL PROTECTED]> wrote:

> On Thu, Jul 25, 2013 at 9:11 AM, Withers, Robert
> <[EMAIL PROTECTED]> 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                       [EMAIL PROTECTED]
> HighWire | Stanford University          http://highwire.stanford.edu/
> +1 650 7237294 (Work)                   +1 650 7259335 (Fax)
>