On Tue, Feb 14, 2017 at 9:21 AM, Ben Chambers <bchamb...@google.com.invalid> wrote:
> > > * I also think there are data source specific metrics that a given IO > will > > want to expose (ie, things like kafka backlog for a topic.) UnboundedSource has API for backlog. It is better for beam/runners to handle backlog as well. Of course there will be some source specific metrics too (errors, i/o ops etc).
