Hi Achanta, Your use case is quite interesting. If I do not understand wrong you want to use a transaction that atomically consume on message from a partition and send it to another partition correct? I pre-assume by saying "remove the message from that partition" you actually mean to skip consuming it in the future?
Currently Kafka does not have functionality to remove a message from the log. And I am not sure what you mean by "access a message"? Guozhang On Thu, Jun 5, 2014 at 11:32 AM, Achanta Vamsi Subhash < achanta.va...@flipkart.com> wrote: > Hi, > > We are experimenting Kafka for a MQ use-case. We found it very useful but > couldn't find the following info from the documentation: > > I have a consumer logic which can say that a message consumption failed. Is > there any way I can remove the message from that partition and put it in > other topic? Can be done in an equivalent way to a database transaction, > importantly: can i do either both or none? > > - How can I remove a message of a particular topic? Is there any > client-api for it? > - How can I access a message? Is there any client-api for it? > > -- > Regards > Vamsi Subhash > -- -- Guozhang
