If you are using ZookeeperConsumerConnector, you can delete your consumers state from zookeeper (/consumers/<your-consumer-group>) and then restart the consumer with the auto.offset.reset option set to "largest"
Thanks, Neha On Mon, Apr 15, 2013 at 3:33 PM, Alex Zuzin <[email protected]> wrote: > Hi all, > > an 0.8 n00b question: how does one start consuming at the current end of the > stream? > In other words, how does a consumer wind the entire topic through upon > connection? > > > Thank you, > -- > "If you can't conceal it well, expose it with all your might" > Alex Zuzin >
