Thanks, Jim. I saw that in the 0.8 config as well. I am trying to write a REST service that dumps all traffic in a given topic/partition. The issue I seem to be facing now is the blocking API of the consumerIterator. Is there any way we can ask whether the traffic is drained? Perhaps a way to correlate topic/partition/thread/latestOffsetPerGroupId, maybe in the PartitionTopicInfo? I see consumed and fetched offsets, but not a written offset.
How about a non-blocking API for the iterator: has that been discussed or spiked? thanks, rob On Jul 25, 2013, at 11:24 AM, 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)
