THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Add waitTimeMs in FetchResponse()
- In Kafka API handler (in handleFetchRequest() function), when creating FetchResponse(), set the waitTimeMs as the time spent in purgatory for FetchResponse()purgatory
- In Follower broker, in processFetchRequest(), it will track the duration latency of fetch request and minus the waitTimeMs from FetchResponseTimeFetchResponse.
- In FetcherStats, we will add a new histogram to track this calculated "true" fetch latency.
- Create a sensor to report this metrics.
Also, additionally, at leader side, we will also add a new metric called TotalEffectiveTime, which is TotalTime minus RemoteTime.
...