Versions Compared

Key

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

...

  1. Add waitTimeMs in FetchResponse()
  2. In Kafka API handler (in handleFetchRequest() function),  when creating FetchResponse(),  set the waitTimeMs as the time spent in purgatory for FetchResponse()purgatory 
  3. In Follower broker,  in processFetchRequest(),  it will track the duration latency of fetch request and minus the waitTimeMs from FetchResponseTimeFetchResponse
  4. In FetcherStats, we will add a new histogram to track this calculated "true" fetch latency.
  5. 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. 

...