THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
AlterReplicaDirResponse => topics topics => [AlterReplicaDirResponseTopic] AlterReplicaDirResponseTopic => topic partitions topic => str partitions => [AlterReplicaDirResponsePartition] AlterReplicaDirResponsePartition => partition error_code partition => int32 error_code => int16 |
Create DescribeLogDirsRequest
| Code Block |
|---|
DescribeLogDirsRequest => topics topics => DescribeLogDirsRequestTopic // If this is empty, all topics will be queried DescribeLogDirsRequestTopic => topic partitions topic => str partitions => [int32] |
Create DescribeLogDirsResponse
| Code Block |
|---|
DescribeLogDirsResponse => log_dirs log_dirs => [DescribeLogDirsResponseDirMetadata] DescribeLogDirsResponseDirMetadata => error_code path topics error_code => int16 path => str topics => [DescribeLogDirsResponseTopic] DescribeLogDirsResponseTopic => topic partitions topic => str partitions => [DescribeLogDirsResponsePartition] DescribeLogDirsResponsePartition => partition size offset_lag is_temporary partition => int32 size => int64 offset_lag => int64 // If this is not a temporary replica, then offset_lag = max(0, HW - LEO). Otherwise, offset_lag = primary Replica's LEO - temporary Replica's LEO is_temporary => boolean // True if replica is *.move |
Broker Config
1) Add config intra.broker.throttled.rate. This config specified the maximum rate in bytes-per-second that can be used to move replica between log directories. This config defaults to MAX_LONG. The intra.broker.throttled.rate is per-broker and the specified capacity is shared by all replica-movement-threads.
2) Add config num.replica.movealter.log.dirs.threads. This config specified the number of threads in ReplicaMoveThreadPool. The thread in this thread pool is responsible to moving replica between log directories. This config defaults to the number of log directories. Note that we typically expect 1-1 mapping between log directories and disks. Thus setting the config to number of log directories by default provides a reasonable way to keep the movement capacity in proportion with the number of disks.
...