Skip to main content

Module admin

Module admin 

Source
Expand description

Kafka administration API.

Structs§

AclBinding
One concrete Kafka ACL binding.
AclFilter
Filter used by Kafka ACL describe and delete operations.
AdminClient
Kafka administration client.
AlterClientQuotaEntryResult
Per-entity result returned by AdminClient::alter_client_quotas.
AlterClientQuotasResult
Result returned by AdminClient::alter_client_quotas.
AlterConfigResourceResult
Outcome for one resource in a classic or incremental AlterConfigs operation.
AlterConfigsOptions
Options shared by classic and incremental AlterConfigs operations.
AlterConfigsResult
Complete response from one classic or incremental AlterConfigs operation.
AlterConsumerGroupOffsetsPartitionResult
One OffsetCommit partition outcome.
AlterConsumerGroupOffsetsResult
Complete response from one administrative OffsetCommit v2 operation.
AlterConsumerGroupOffsetsTopicResult
OffsetCommit results for one topic.
AlterPartitionReassignmentResult
Per-partition outcome returned by AlterPartitionReassignments.
AlterPartitionReassignmentTopicResult
Per-topic outcomes returned by AlterPartitionReassignments.
AlterPartitionReassignmentsResult
Result returned by AdminClient::alter_partition_reassignments.
AlterScramCredentialResult
Per-user outcome returned by AlterUserScramCredentials.
AlterUserScramCredentialsResult
Result returned by AdminClient::alter_user_scram_credentials.
BrokerDescription
Broker metadata returned by AdminClient::describe_cluster.
ClientQuotaAlteration
One compound client quota alteration.
ClientQuotaEntity
A compound Kafka client quota entity.
ClientQuotaEntityComponent
One typed entity component in a client quota entity.
ClientQuotaEntry
One entity and its quota values.
ClientQuotaFilter
Filter used by AdminClient::describe_client_quotas.
ClientQuotaFilterComponent
One component in a client quota describe filter.
ClientQuotaOperation
One client quota value alteration.
ClientQuotaValue
One quota key/value returned by Kafka.
ClusterDescription
Kafka cluster metadata returned by AdminClient::describe_cluster.
ConfigAlterOperation
One operation in an incremental Kafka configuration update.
ConfigEntry
One Kafka configuration entry.
ConfigResourceResult
Configuration result for one Kafka resource.
ConfigSynonym
One synonym contributing to a Kafka configuration value.
ConsumerGroupDescription
Description of one Kafka consumer group.
ConsumerGroupMember
One member in a Kafka consumer group description.
ConsumerGroupOffset
One committed consumer-group offset to set administratively.
ConsumerGroupOffsetDelete
Topic partitions whose committed offsets should be deleted for a group.
ConsumerGroupOffsetPartitionResult
One OffsetFetch partition outcome.
ConsumerGroupOffsetQuery
A topic and partition filter for consumer-group offset inspection.
ConsumerGroupOffsetTopicResult
OffsetFetch results for one topic.
CreateAclsEntryResult
Per-binding result returned by AdminClient::create_acls.
CreateAclsResult
Result returned by AdminClient::create_acls.
CreatePartitionsOptions
Options for one CreatePartitions operation.
CreatePartitionsResult
Complete response from one CreatePartitions operation.
CreatePartitionsTopicResult
Outcome for one topic in a CreatePartitions response.
CreateTopicResult
Outcome for one topic in a CreateTopics response.
CreateTopicsOptions
Options for one CreateTopics operation.
CreateTopicsResult
Complete response from one CreateTopics operation.
DeleteAclsFilterResult
Per-filter result returned by AdminClient::delete_acls.
DeleteAclsResult
Result returned by AdminClient::delete_acls.
DeleteConsumerGroupOffsetsPartitionResult
Offset-deletion outcome for one topic partition.
DeleteConsumerGroupOffsetsResult
Complete response from one OffsetDelete operation.
DeleteConsumerGroupOffsetsTopicResult
Offset-deletion outcomes for one topic.
DeleteConsumerGroupResult
Outcome for one group in AdminClient::delete_consumer_groups.
DeleteRecordsOptions
Options for one DeleteRecords operation.
DeleteRecordsPartition
Partition offset target for one DeleteRecords operation.
DeleteRecordsPartitionResult
Outcome for one partition in a DeleteRecords response.
DeleteRecordsResult
Complete response from one DeleteRecords operation.
DeleteRecordsTopic
Topic and partition targets for one DeleteRecords operation.
DeleteRecordsTopicResult
Outcome for one topic in a DeleteRecords response.
DeleteTopicResult
Outcome for one topic in a DeleteTopics response.
DeleteTopicsOptions
Options for one DeleteTopics operation.
DeleteTopicsResult
Complete response from one DeleteTopics operation.
DeletedAclResult
Per-ACL deletion result nested under a delete filter result.
DescribeAclsResult
Result returned by AdminClient::describe_acls.
DescribeClientQuotasResult
Result returned by AdminClient::describe_client_quotas.
DescribeConfigsOptions
Options for one DescribeConfigs operation.
DescribeConfigsResult
Complete response from one DescribeConfigs operation.
DescribeProducersActiveProducer
Active producer sequence state returned by Kafka.
DescribeProducersPartitionResult
Producer state for one partition in a DescribeProducers response.
DescribeProducersResult
Complete response from one DescribeProducers operation.
DescribeProducersTopic
Topic and partition targets for one DescribeProducers operation.
DescribeProducersTopicResult
Outcome for one topic in a DescribeProducers response.
DescribeTransactionsResult
Complete response from one DescribeTransactions operation.
DescribeUserScramCredentialsResult
Result returned by AdminClient::describe_user_scram_credentials.
GroupListing
One Kafka group returned by AdminClient::list_groups.
ListConsumerGroupOffsetsResult
Complete response from one OffsetFetch v2 consumer-group offset query.
ListPartitionReassignmentsResult
Result returned by AdminClient::list_partition_reassignments.
ListTransactionsOptions
Filters for AdminClient::list_transactions.
ListTransactionsResult
Complete response aggregated from all ListTransactions broker shards.
ListedTransaction
One active transaction returned by ListTransactions.
NewPartitions
New total partition count for an existing Kafka topic.
NewTopic
Definition of one Kafka topic to create.
OngoingPartitionReassignment
An ongoing reassignment returned by ListPartitionReassignments.
OngoingPartitionReassignmentTopic
Ongoing reassignments for one topic.
PartitionReassignment
A topic and partition set submitted to AlterPartitionReassignments.
PartitionReassignmentOptions
Options shared by partition reassignment start and status requests.
PartitionReassignmentPartition
One partition target in a PartitionReassignment.
PartitionReassignmentQuery
A topic and optional partition filter for ListPartitionReassignments.
ScramCredentialDeletion
A SCRAM credential deletion request.
ScramCredentialInfo
One SCRAM mechanism and iteration count returned for a Kafka user.
ScramCredentialUpsertion
A SCRAM credential upsertion request.
ScramUserCredentials
Credentials and per-user outcome returned by DescribeUserScramCredentials.
TopicConfigAlteration
Incremental configuration changes for one Kafka topic.
TopicConfigResource
One Kafka topic whose configuration should be described.
TopicConfigUpdate
Complete dynamic topic configuration values for one topic in classic AlterConfigs.
TopicConfigUpdateEntry
One configuration entry in a classic TopicConfigUpdate.
TopicListing
One topic returned by AdminClient::list_topics.
TransactionDescription
State of one transactional ID returned by Kafka.
TransactionDescriptionTopic
Topic partitions currently associated with one transaction.

Enums§

AclOperation
Kafka ACL operation.
AclPatternType
Kafka ACL resource pattern type.
AclPermissionType
Kafka ACL permission type.
AclResourceType
Kafka ACL resource type.
ClientQuotaMatchType
How a client quota filter matches an entity name.
ConfigAlterOperationKind
Kafka IncrementalAlterConfigs operation kind.
ConfigSource
Kafka configuration source classification.
ScramCredentialMechanism
SCRAM mechanism identifiers accepted by Kafka’s credential administration APIs.