...
LEVEL 0 | LEVEL 1 | LEVEL 2 | LEVEL 3 | LEVEL 3 | LEVEL 3 | |
Per-Client | Per-Thread | Per-Task | Per-Processor-Node | Per-State-Store | Per-Cache | |
---|---|---|---|---|---|---|
TAGS | type=stream-metrics,client-id=[client-id] | type=stream-thread-metrics,thread-name=[threadId] (! tag name changed) | type=stream-task-metrics,thread-name=[threadId],task-id=[taskId] (! tag name changed) | type=stream-processor-node-metrics,thread-name=[threadId],task-id=[taskId],processor-node-id=[processorNodeId] (! tag name changed) | stream-state-metrics,clientthread-idname=[threadId],thread-name=[taskId],[storeType]-state-id=[storeName] (! tag name changed) | type=stream-record-cache-metrics,thread-name=[threadId],task-id=[taskId],record-cache-id=[storeName] (! tag name changed) |
version | commit-id (static gauge) | INFO ($) | |||||
application-id (static gauge) | INFO ($) | |||||
topology-description (static gauge) | INFO ($) | |||||
state (dynamic gauge) | INFO ($) | |||||
rebalance-latency (avg | max) | INFO ($) | |||||
rebalance (rate | total) | INFO ($) | |||||
last-rebalance-time (dynamic gauge) | INFO ($) | |||||
active-task-process (ratio) | INFO ($) | |||||
standby-task-process (ratio) | INFO ($) | |||||
process-latency (avg | max) | INFO | DEBUG | (! removed for now) | |||
process (rate | total) | INFO | DEBUG ( → ) on source-nodes only | DEBUG | |||
punctuate-latency (avg | max) | INFO | DEBUG | ||||
punctuate (rate | total) | INFO | DEBUG | ||||
commit-latency (avg | max) | INFO | DEBUG | ||||
commit (rate | total) | INFO | DEBUG | ||||
poll-latency (avg | max) | INFO | |||||
poll (rate | total) | INFO | |||||
task-created | closed (rate | total) | INFO | |||||
enforced-processing (rate | total) | DEBUG | |||||
record-lateness (avg | max) | DEBUG | |||||
dropped-late-records (rate | total) | INFO * (window processor only) (! name changed) | |||||
suppression-emit (rate | total) | DEBUG * (suppress processor only) | |||||
skipped-records (rate | total) | (! moved to lower level) | INFO * ( → ) | INFO * (few processors + record queue only) | |||
suppression-buffer-size (avg | max) | DEBUG * (suppression buffer only) | |||||
suppression-buffer-count (avg | max) | DEBUG * (suppression buffer only) | |||||
expired-window-record-drop (rate | total) | DEBUG * (window store only) | |||||
put | put-if-absent .. | get-latency (avg | max) | DEBUG * (excluding suppression buffer) (! name changed) | |||||
put | put-if-absent .. | get (rate) | DEBUG * (excluding suppression buffer) (! name changed) | |||||
hit-ratio (avg | min | max) | DEBUG (! name changed) |
...