For mine topic the offset isn't increasing which means the consumer has
stopped. I wanted to get the count(#) of events that are still remaining to
be processed. Is that possible ?



On Mon, Dec 9, 2013 at 9:44 PM, Jun Rao <jun...@gmail.com> wrote:

> By default, each topic is kept on the broker for 7 days. Older data,
> whether consumed or not, will be deleted.
>
> 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)
>
> Thanks,
>
> Jun
>
>
> On Mon, Dec 9, 2013 at 4:30 AM, Sanket Maru <san...@ecinity.com> wrote:
>
> > I am working on a small project and discovered that our consumer hasn't
> > been executed for over a month now.
> >
> > How can i check the unprocessed events ? From which date the events are
> > available and what is the retention policy on the producer side ?
> >
> > Thanks,
> > Sanket Maru
> >
>

Reply via email to