Mark, Currently, there is no reset API in the consumer. We are thinking about how to add that properly in the future. For your use case, you can potentially increase the degree of parallelism in the consumer to drive up the consumption rate or throttle the consumption in your app.
Thanks, Jun On Sun, May 6, 2012 at 8:36 PM, Mark Grabois <mark.grab...@trendrr.com>wrote: > Hello, > > I know the topic of consumer offsets has come up frequently on the list, > how it is not possible to control the offset without using SimpleConsumer. > I would like to be able to reset all consumer offsets to "largest" (so that > consumption may start with the latest produced messages) when consumption > begins to lag behind our data feed. Is there a good way to do it with > zookeeper (since we will be using multiple consumers), without restarting > consumer? > > Thank you, > Mark >
