For your first question, I don't know of a way to do that. For the second question, consumers commit the offset after every/a few reads. When the consumer restarts, it starts from the last committed offset.
On Tue, Sep 9, 2014 at 7:23 PM, siddharth ubale <siddharth.ub...@gmail.com> wrote: > Hi Guys, > > I wanted to know if we can store data sent to consumers via brokers on to > any database like how ActiveMQ persists data to kahaDB or any other Db like > PostGRE,SQL etc. > > Also,when the broker is sending message to consumer and consumer fails, so > when the consumer is up again will the consumer pick data from where it > last left or will it start reading from beginning if i have set the > consumer from beginning while coding the consumer. > > Thanks, > Siddharth Ubale >
