THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
ChangeReplicaDirResponse => error_code partitions error_code => int16 partitions => [ChangeReplicaDirResponsePartition] ChangeReplicaDirResponsePartition => topic partition error_code topic => str partition => int32 error_code => int16 |
Create DescribeDirsRequest
Code Block |
---|
DescribeDirsRequest => log_dirs log_dirs => [str] |
Create DescribeDirsResponse
Code Block |
---|
DescribeDirsResponse => log_dirs log_dirs => [DescribeDirsResponseDirMetadata] DescribeDirsResponseDirMetadata => error_code path topics error_code => int16 path => str topics => [DescribeDirsResponseTopic] DescribeDirsResponseTopic => topic partitions topic => str partitions => [DescribeDirsResponsePartition] DescribeDirsResponsePartition => partition size partition => int32 size => int64 |
Metrics
Here are the metrics we need to add as part of this proposal
...
Scripts
1) Add kafka-log-dirs.sh which allows user to get list of replicas per log directory on a broker.
...