Want to capture flow related metrics: - records consumed - records produced - time delay (processing lag)
Want to capture flow related metrics: