Consumer offsets are typically checkpointed into ZK. To check # of unconsumed messages, you can either use the ConsumerOffsetChecker tool (see https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Myconsumerseemstohavestopped%2Cwhy%3F) or use the maxlag jmx in the consumer application (see http://kafka.apache.org/documentation.html#consumerconfigs)
Currently, we don't have an api to translate from an offset to timestamp. Do you want the timestamp when the message is added to the broker? Thanks, Jun On Sun, Dec 8, 2013 at 11:57 PM, Bhargav <bharga...@cleartrip.com> wrote: > Hi, > > > How to know where to start consuming from, if we have already consumed a > few messages. Some where in between latest and the earliest? How to > identify the timestamp or offset from the api. > > Thanks, > Bhargav > > -- > >
