Jeff Klukas created KAFKA-3715: ---------------------------------- Summary: Higher granularity streams metrics Key: KAFKA-3715 URL: https://issues.apache.org/jira/browse/KAFKA-3715 Project: Kafka Issue Type: Improvement Components: streams Reporter: Jeff Klukas Assignee: Guozhang Wang Priority: Minor Fix For: 0.10.1.0
Originally proposed by [~guozhang] in https://github.com/apache/kafka/pull/1362#issuecomment-218326690 We can consider adding metrics for process / punctuate / commit rate at the granularity of each processor node in addition to the global rate mentioned above. This is very helpful in debugging. We can consider adding rate / total cumulated metrics for context.forward indicating how many records were forwarded downstream from this processor node as well. This is helpful in debugging. We can consider adding metrics for each stream partition's timestamp. This is helpful in debugging. Besides the latency metrics, we can also add throughput latency in terms of source records consumed. -- This message was sent by Atlassian JIRA (v6.3.4#6332)