Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...


LEVEL 0LEVEL 1LEVEL 2LEVEL 3LEVEL 3LEVEL 3

Per-Client

Per-Thread

Per-Task 

Per-Processor-Node Per-State-StorePer-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)

INFODEBUG(! removed for now)

process (rate | total)

INFODEBUG ( → ) on source-nodes onlyDEBUG

punctuate-latency (avg | max)

INFODEBUG


punctuate (rate | total)

INFODEBUG


commit-latency (avg | max)

INFODEBUG


commit (rate | total)

INFODEBUG


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)

...