Crate crabka_client_admin 

Admin client for the operator. Targets one cluster’s controller; plaintext only.

Built on crabka_client_core::Connection’s typed send::<R: ProtocolRequest> so request-version negotiation is automatic via the ApiVersionTable populated at connect time.

Re-exports

pub use configs::AlterConfigsOutcome;

pub use configs::IncrementalAlterOp;

pub use configs::TopicConfigOverrides;

pub use log_dirs::AlterReplicaLogDirOutcome;

pub use log_dirs::LogDirInfo;

pub use log_dirs::LogDirPartitionInfo;

pub use log_dirs::LogDirTopicInfo;

pub use quotas::QuotaOp;

pub use quotas::UserQuotaConfig;

pub use quotas::diff_user_quotas;

pub use topics::CreatePartitionsOp;

pub use topics::CreatePartitionsOutcome;

pub use topics::CreateTopicOutcome;

pub use topics::CreateTopicSpec;

pub use topics::DeleteTopicOutcome;

pub use topics::TopicMetadata;

pub use topics::TopicMetadataEntry;

pub use users::AclEntry;

pub use users::AclEntryFilter;

pub use users::AclOperation;

pub use users::CreateAclOutcome;

pub use users::DEFAULT_SCRAM_ITERATIONS;

pub use users::DeleteAclFilterOutcome;

pub use users::PatternType;

pub use users::PermissionType;

pub use users::ResourceType;

pub use users::ScramDeletion;

pub use users::ScramUpsertion;

pub use users::ScramUserOutcome;

Modules

configs

Topic-config wrappers.

delegation_tokens

KIP-48: delegation-token RPCs on AdminClient.

log_dirs

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

quotas

Client-quota admin RPCs.

topics

Topic CRUD wrappers.

users

KafkaUser admin RPCs.

Structs

AdminClient

Short-lived admin client targeting one cluster’s controller. Optionally negotiates TLS/SASL via AdminClient::connect_secured.

KafkaError

A Kafka-level error attached to a single per-resource outcome.

Enums

AdminError

Traits

AdminClientLike

Test seam for AdminClient. The operator’s reconcile only needs dynamic dispatch via this trait; production code wraps a concrete AdminClient, while tests substitute a fake.