Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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.

Thanks,

Jun

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

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB