Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Add waitTimeMs in FetchResponse()
  2. In processResponseCallback() of handleFetchRequestKafka API handler (in handleFetchRequest() function),  set the waitTimeMs as the time spent in purgatory .for FetchResponse()
  3. 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. 

...