THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Add waitTimeMs in FetchResponse()
- In processResponseCallback() of handleFetchRequestKafka API handler (in handleFetchRequest() function), set the waitTimeMs as the time spent in purgatory .for FetchResponse()
- In Follower broker, in processFetchRequest(), it will track the duration of fetch request and minus the waitTimeMs from FetchResponseTime. In FetcherStats, we will In FetcherStats, add a new meter to track the real this calculated fetch latency, by deducting the waitTimeMs.
Also, in FetchLatency, we should also report time , additionally, at leader side, we will also add a new metric called TotalEffectiveTime, which is TotalTime minus RemoteTime.
...