Re: Monitor all stream consumers for lag

2017-08-01 Thread Garrett Barton
Oh that makes a lot of sense now that I think of it. GlobalStores cannot be part of a group since they have to consume the entire stream per instance. On Tue, Aug 1, 2017 at 10:18 AM, Damian Guy wrote: > Hi Garrett, > > The global state store doesn't use consumer groups and doesn't commit > off

Re: Monitor all stream consumers for lag

2017-08-01 Thread Damian Guy
Hi Garrett, The global state store doesn't use consumer groups and doesn't commit offsets. The offsets are checkpointed to local disk, so they won't show up with the ConsumerGroupCommand. That said it would be useful to see the lag, so maybe raise a JIRA for it? Thanks, Damian On Tue, 1 Aug 201