`commitTimeSensor`, `processTimeSensor`, and `punctuateTimeSensor` are being 
used like `timeSensor.record(latencyTime / numberOfOps)`, which measures the 
average latency for a batch of operations, but rate and total metrics were not 
being computed correctly. This PR adds a throughput sensor for each of commit, 
process, and punctuate operations which is used like 
`thoughputSensor.record(numberOfOps)`.

Unfortunately I don't have time right now to add tests, but because I already 
had this change started I wanted to submit a PR so it wouldn't get forgotten 
about. 

### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation 
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)


[ Full content available at: https://github.com/apache/kafka/pull/5555 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to