Major Description
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.
Attachments
Issue Links
- links to
- mentioned in
-
Page Loading...