这个意识是这样的，我们有一个如下的场景： 一个A系统往kafka队列写消息，一个B系统负责从kafka消费消息 现可能由于某种原因B系统无法读取kafka的消息，此时A系统还一直在往队列写消息，所以当我们把B系统 修复起来后（比如说花了2天时间修复了），我们不想让B系统还从原来的offset读取数据，而是想从某个时间点开始读取数据， 不知道kafka有类似的 时间戳和offset对应的接口没？
From: Guozhang Wang Date: 2013-10-21 12:49 To: users@kafka.apache.org; kojie.fu Subject: Re: how can i use offset filter the msg Hello, I do not fully understanding your question, did you mean that you want to know when a message with certain offset is produced? Guozhang On Sun, Oct 20, 2013 at 8:54 PM, kojie.fu <kojie...@gmail.com> wrote: > Hi all, > we have a scene like this: > A system produce the msg ,B system comsumer the msg. > for some reason the B system unwork,and then we need abandon the out of > date msg. > but now in our msg there is no time stamp. > how can i use the offset to do this. > > does kafka know when the msg produce? > > how can i location the certain offset? > > > > thanks -- -- Guozhang
