smjn opened a new pull request, #22412:
URL: https://github.com/apache/kafka/pull/22412
* Stitched `ShareGroupMetrics` with `ShareGroupDLQStateManager `. This
includes 3 metrics defined in KIP-1191:
* total records written - incremented on success response from produce RPC
* produce requests total per group per sec - incremented for each new
handler enqueued for produce
* produce requests failed per group per sec - incremented for every
handler with failed produce response
* New tests have been added to `ShareGroupDLQStateManagerTest` to test
batching and metrics.
* Currently, ownership of `ShareGroupMetrics` was with
`SharePartitionManager` which has been modified. Now the owner is
`BrokerServer` which passes the object to SPM and SGDSM. Closing the metrics is
also done by the `BrokerServer`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
