Xianxin Lin
11/19/2025, 8:32 PMCollected metrics:
Backlog information at each source
Incoming data rate at the sources (e.g. records/sec written into the Kafka topic)
Record processing rate at each job vertex
Busy and backpressured time at each job vertex