Versions Compared

Key

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

...

Add waitTimeMs in FetchResponse, and bump the FetchResponse and FetchRequest API version. 

Proposed Changes

...

  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 
  3. In Follower broker,  in processFetchRequest(),  it will track the latency of fetch request and minus the waitTimeMs from FetchResponse. 
  4. In FetcherStats, we will add a new histogram to track this calculated "true" fetch latency.
  5. Create a sensor to report this We can also extend that to consumer fetch latency metrics. 

Also, additionally,  at leader side, we will also add a new metric called TotalEffectiveTime, which is TotalTime minus RemoteTime. 

...