Re: [DISCUSS] Offset checkpoint notification to the System Consumer

Link, to save folks some time: https://issues.apache.org/jira/browse/SAMZA-1042 I'll take a look and post any comments in the JIRA soon. On Tue, Oct 25, 2016 at 9:37 AM, Boris Shkolnik wrote: > Currently we keep track of the progress of each consumer using > checkpointing mechanism. These check

Re: Review Request 52492: Adding monitor to clean up stale local stores of jobs/tasks.

> On Oct. 25, 2016, 9:31 p.m., Jagadish Venkatraman wrote: > > samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitor.java, > > line 166 > > > > > > JobsClient seems to be a generic class and not really