I have an app that is consuming multiple topics, and punctuating on stream time. I know that punctuate is driven by the min time of all the partitions of all the topics driving the transformer that I am punctuating on. When I deploy my app and punctuate is not called as I expect, what tools do I have to understand where time is per instance/thread/topic/partition? Does Kafka Streams expose stats for this?
I would like something like a stat of something like: Kafka Streams Instance / Kafka Stream Thread / Topic / Partition / EventTime = 1522693495291 Then I can look at which topic/partition is lagging to debug my problem. Does something like this exist? Is this a reasonable feature request? Thanks! Dan
