THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Config | Use case | |||
|---|---|---|---|---|
| fetch.max.bytes | Maximum bytes expected for the entire fetch response. | |||
| failed.authentication.delay | Connection close delay on failed authentication. | |||
| replica.fetch.response.max.bytes | Maximum bytes expected for the entire fetch response. | |||
| replica.fetch.wait.max.ms | Max wait time for each fetcher request issued by follower replicas. | |||
| followerreplica.fetch.replication.throttled (new config to add) | Should all replication follower throttle | leader.replication.throttled (new config to add) | backoff.ms | The amount of time to sleep when fetch partition error occurs. |
| replica.fetch.response.max.bytes | Maximum bytes expected for the entire fetch response. Should all replication leader throttle |
fetch.max.bytes: ReplicaManager will multi-inherit from BrokerReconfigurable but no reconfigurable interfaces need to be implemented since the fetcher request will calculate fetchMaxBytes as the minimum of fetchRequest.maxBytes and config.fetchMaxBytes
...
replica.fetch.wait.max.ms: The changes are similar to replica.fetch.response.max.bytes
follower.replication.throttled: A new class variable LeaderReplicationThrottledProp will be added to ReplicationQuotaManager. Similar to leader.replication.throttled.rate, the BrokerConfigHandler will call updateBrokerThrottle() and update this class variable upon receiving the config change notification from ZooKeeper. ReplicationQuotaManager::isThrottled() will have its logic modified and judge based on if all the replication follower is throttled.
leader.replication.throttled: Similar to follower.replication.throttled
Public Interfaces
This KIP introduces two new broker level configs related to replication throttle:
...