...
- The below broker config will be added to the RemoteLogManagerConfig
remote.list.offsets.request.timeout.ms
: to define the timeout for the remote list offsets requests. This will be a dynamic config and defaults to 30 seconds.
- Metric to emit the expired DelayedRemoteListOffsets request.
kafka.server:type:DelayedRemoteListOffsetsMetrics,name=ExpiresPerSec,topic=([-.\w]+),partition=([0-9]+)
- PurgatoryName = RemoteListOffsets
- A new TimeoutMs field will be added to the ListOffsetsRequest to convey the client timeout to the server.
Proposed Changes
The LIST_OFFSETS API is invoked by:
...