Module log_dirs 

KIP-113 admin RPCs: AlterReplicaLogDirs (api_key 34) and DescribeLogDirs (api_key 35).

Both act only on the broker that receives the request. As Kafka’s KafkaAdminClient.describeLogDirs and alterReplicaLogDirs do, the admin client finds each broker by id in the metadata and sends one request to each broker (ConstantNodeIdProvider). A broker that fails gives an error for that broker only.

Structs

LogDirInfo

One log dir from a DescribeLogDirs response, as Kafka’s LogDirDescription.

LogDirPartitionInfo

LogDirTopicInfo

ReplicaLogDir

Where one replica of a partition lives on its broker.

ReplicaLogDirInfo

The log dirs of one replica, as Kafka’s DescribeReplicaLogDirsResult.ReplicaLogDirInfo. A replica that the broker does not hold, or holds only in an offline log dir, has neither.

TopicPartitionReplica

One replica of a partition on one broker, as Kafka’s TopicPartitionReplica.

Type Aliases

BrokerResult

The result of one broker: its value, or the Kafka error of the broker.