This repository was archived by the owner on Jul 31, 2026. It is now read-only.

NMS-12987: Improve Observability - #27

Draft

swachter wants to merge 2 commits into

Commits on Jun 29, 2021

NMS-12987: use gauges instead of distributions (distributions are not supported by the combination Beam/Flink/Prometheus)
swachter
committed
d17664a
NMS-12987: report currentTimeMillis - flow.lastSwitched as kafka_drift (watermarks are also based on lastSwitched)
swachter
committed
5d60229