THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Add waitTimeMs in FetchResponse, and bump the FetchResponse and FetchRequest protocol version.
| Code Block | ||
|---|---|---|
| ||
FetchResponse => TransactionalId RequiredAcks Timeout [FetchableTopicResponse] ThrottleTimeMs => INT32 WaitTimeMs => INT32 # Add a new field to record the request wait time in purgatory Timeout => INT32 ErrorCode => INT16 SessionId => INT32 FetchableTopicResponse => [Name [FetchablePartitionResponse] PreferredReadReplica Records] ...... |
Proposed Changes
We like to propose to track the real end to end fetch latency with those changes:
...