Expand description
KafkaUser admin RPCs.
Five admin operations the KafkaUser reconciler drives:
AlterUserScramCredentials (upsert + delete in a single call),
CreateAcls, DeleteAcls, DescribeAcls.
Wire i8 discriminants stay private to this module. Callers use the typed
Rust enums below. crates/client-admin depends on krabka-metadata for
shared image types such as DelegationToken, but it stays free of
krabka-broker, so out-of-process clients can use the crate. Unit tests
cover the wire round-trip of the local enum copies.
Structs§
- AclEntry
- A concrete, non-filter, ACL entry with every field populated. It matches the shape the broker stores in its metadata image.
- AclEntry
Filter - Filter for
DescribeAcls/DeleteAcls. EachNoneaxis matches anything. - AclEntry
Filter Builder - Use builder syntax to set the inputs and finish with
build(). - Create
AclOutcome - Delete
AclFilter Outcome - Scram
Deletion - Scram
Iterations - Broker-valid PBKDF2 iteration count for a SCRAM credential.
- Scram
Upsertion - Scram
User Outcome - User
Scram Credential - User
Scram Credentials
Enums§
Constants§
- DEFAULT_
SCRAM_ ITERATIONS - Default PBKDF2 iteration count for new Kafka SCRAM credentials.
- MAX_
SCRAM_ ITERATIONS - Maximum PBKDF2 iteration count accepted by the broker.
- MIN_
SCRAM_ ITERATIONS - Minimum PBKDF2 iteration count accepted by the broker.