I've often wondered about what it would take to be able to overwrite a specific offset in a partition (it could be very useful for transaction rollbacks, message deletions, etc). Unfortunately, I don't think that feature currently exists.
--Tom On Mon, Apr 1, 2013 at 11:14 PM, Pankaj Misra <pankaj.mi...@impetus.co.in>wrote: > Hi, > > Is it possible for consumer to trigger a message dequeue(message deletion) > from the broker after consuming the message? > > Thanks & Regards > Pankaj Misra > > -----Original Message----- > From: Jason Rosenberg [mailto:j...@squareup.com] > Sent: Tuesday, April 02, 2013 1:30 AM > To: users@kafka.apache.org > Subject: Re: Kafka log retentions > > Essentially, > > There's a configuration property: log.retention.hours > > This determines the minimum time a message will remain available on the > broker. The default is 7 days. > > The kafka broker doesn't keep track of whether the message has been > consumed or not (or how many times it has been consumed). > > It's up to individual consumers to keep track of which message offset > they've consumed (which typically gets saved in zookeeper). > > Jason > > > On Mon, Apr 1, 2013 at 12:50 PM, Philip O'Toole <phi...@loggly.com> wrote: > > > On Mon, Apr 1, 2013 at 12:27 PM, Ankit Jain <ankitjainc...@gmail.com> > > wrote: > > > > > Hi All, > > > > > > Once the message is consumed by consumer, we want it to delete from > > message > > > broker as well. > > > > > > > Kafka doesn't work this way. Read the design doc -- it's well written, > > and should be read by anyone working with Kafka. > > > > http://kafka.apache.org/design.html > > > > > > > > > > > > I was exploring the kafka configuration, but not sure which > > > configuration would full my need. > > > > > > Guys, I need your help. > > > > > > Thanks .. > > > > > > > > > -- > > > Thanks, > > > Ankit Jain > > > > > > > ________________________________ > > > > > > > NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. >
