Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Kafka Offset timestamp

Copy link to this message
Re: Kafka Offset timestamp
Currently, a message doesn't have a timestamp header. So you have to encode
the timestamp in the message payload.



On Mon, Apr 1, 2013 at 7:10 PM, Suyog Rao <[EMAIL PROTECTED]> wrote:

> Is there a way to get the timestamp for a Kafka message entry on the
> server by the consumer? What I would like to do is to is check if an offset
> is of a particular age before pulling offset + bytes to my consumer.
> Otherwise I would like the messages to be continued to be queued in Kafka
> until the consumer is ready. I am using simple consumer and manually
> updating Zookeper.
> Thanks