Currently, a message doesn't have a timestamp header. So you have to encode the timestamp in the message payload.
Thanks, Jun On Mon, Apr 1, 2013 at 7:10 PM, Suyog Rao <su...@loggly.com> 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
