Thanks for the proposed KIP. Overall LGTM. A few comments:
1. "at the granularity of each processor node, in the addition to the global rate" I think you also add one sensor at the granularity of tasks, "Skipped records sensor in StreamTask" right? 2. From PR 1446 it seems you have also added a couple of APIs for allowing users to register arbitrary sensors via `StreamsMetrics`, could you also describe the changes and when / how users are expected to use them as well? 3. Could you also list the added overloaded APIs for throughput sensors as well as with the recordLevel parameters, and mention what will be the default values for those added parameters in the existing API functions? Guozhang On Fri, Dec 30, 2016 at 8:26 PM, Aarti Gupta <aartigup...@gmail.com> wrote: > Hi all, > > I would like to start the discussion on KIP-104: Granular Sensors for > Streams > <https://cwiki.apache.org/confluence/display/KAFKA/KIP-104% > 3A+Granular+Sensors+for+Streams?src=contextnavchildmode> > > *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=67636480 > <https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=67636480 > >* > > Looking forward to your feedback. > > Thanks, > Aarti and Eno > -- -- Guozhang