Package org.apache.kafka.clients.admin

Class Summary

Class	Description
AbstractOptions<T extends AbstractOptions>
AdminClient	The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.
AdminClientConfig	The AdminClient configuration class, which also contains constants for configuration entry names.
AlterConfigOp	A class representing a alter configuration entry containing name, value and operation type.
AlterConfigsOptions	Options for AdminClient.alterConfigs(Map).
AlterConfigsResult	The result of the AdminClient.alterConfigs(Map) call.
AlterReplicaLogDirsOptions	Options for AdminClient.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions).
AlterReplicaLogDirsResult	The result of AdminClient.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions).
Config	A configuration object containing the configuration entries for a resource.
ConfigEntry	A class representing a configuration entry containing name, value and additional metadata.
ConfigEntry.ConfigSynonym	Class representing a configuration synonym of a ConfigEntry.
ConsumerGroupDescription	A detailed description of a single consumer group in the cluster.
ConsumerGroupListing	A listing of a consumer group in the cluster.
CreateAclsOptions	Options for AdminClient.createAcls(Collection).
CreateAclsResult	The result of the AdminClient.createAcls(Collection) call.
CreateDelegationTokenOptions	Options for AdminClient.createDelegationToken(CreateDelegationTokenOptions).
CreateDelegationTokenResult	The result of the KafkaAdminClient.createDelegationToken(CreateDelegationTokenOptions) call.
CreatePartitionsOptions	Options for AdminClient.createPartitions(Map).
CreatePartitionsResult	The result of the AdminClient.createPartitions(Map) call.
CreateTopicsOptions	Options for AdminClient.createTopics(Collection).
CreateTopicsResult	The result of AdminClient.createTopics(Collection).
DeleteAclsOptions	Options for the AdminClient.deleteAcls(Collection) call.
DeleteAclsResult	The result of the AdminClient.deleteAcls(Collection) call.
DeleteAclsResult.FilterResult	A class containing either the deleted ACL binding or an exception if the delete failed.
DeleteAclsResult.FilterResults	A class containing the results of the delete ACLs operation.
DeleteConsumerGroupsOptions	Options for the AdminClient.deleteConsumerGroups(Collection) call.
DeleteConsumerGroupsResult	The result of the AdminClient.deleteConsumerGroups(Collection) call.
DeletedRecords	Represents information about deleted records The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
DeleteRecordsOptions	Options for AdminClient.deleteRecords(Map, DeleteRecordsOptions).
DeleteRecordsResult	The result of the AdminClient.deleteRecords(Map) call.
DeleteTopicsOptions	Options for AdminClient.deleteTopics(Collection).
DeleteTopicsResult	The result of the AdminClient.deleteTopics(Collection) call.
DescribeAclsOptions	Options for AdminClient.describeAcls(AclBindingFilter).
DescribeAclsResult	The result of the AdminClient.describeAcls(AclBindingFilter) call.
DescribeClusterOptions	Options for AdminClient.describeCluster().
DescribeClusterResult	The result of the AdminClient.describeCluster() call.
DescribeConfigsOptions	Options for AdminClient.describeConfigs(Collection).
DescribeConfigsResult	The result of the AdminClient.describeConfigs(Collection) call.
DescribeConsumerGroupsOptions	Options for AdminClient.describeConsumerGroups(Collection, DescribeConsumerGroupsOptions).
DescribeConsumerGroupsResult	The result of the KafkaAdminClient.describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)} call.
DescribeDelegationTokenOptions	Options for AdminClient.describeDelegationToken(DescribeDelegationTokenOptions).
DescribeDelegationTokenResult	The result of the KafkaAdminClient.describeDelegationToken(DescribeDelegationTokenOptions) call.
DescribeLogDirsOptions	Options for AdminClient.describeLogDirs(Collection) The API of this class is evolving, see AdminClient for details.
DescribeLogDirsResult	The result of the AdminClient.describeLogDirs(Collection) call.
DescribeReplicaLogDirsOptions	Options for AdminClient.describeReplicaLogDirs(Collection).
DescribeReplicaLogDirsResult	The result of AdminClient.describeReplicaLogDirs(Collection).
DescribeReplicaLogDirsResult.ReplicaLogDirInfo
DescribeTopicsOptions	Options for AdminClient.describeTopics(Collection).
DescribeTopicsResult	The result of the AdminClient.describeTopics(Collection) call.
ElectPreferredLeadersOptions	Options for AdminClient.electPreferredLeaders(Collection, ElectPreferredLeadersOptions).
ElectPreferredLeadersResult	The result of AdminClient.electPreferredLeaders(Collection, ElectPreferredLeadersOptions) The API of this class is evolving, see AdminClient for details.
ExpireDelegationTokenOptions	Options for AdminClient.expireDelegationToken(byte[], ExpireDelegationTokenOptions).
ExpireDelegationTokenResult	The result of the KafkaAdminClient.expireDelegationToken(byte[], ExpireDelegationTokenOptions) call.
KafkaAdminClient	The default implementation of AdminClient.
ListConsumerGroupOffsetsOptions	Options for AdminClient.listConsumerGroupOffsets(String).
ListConsumerGroupOffsetsResult	The result of the AdminClient.listConsumerGroupOffsets(String) call.
ListConsumerGroupsOptions	Options for AdminClient.listConsumerGroups().
ListConsumerGroupsResult	The result of the AdminClient.listConsumerGroups() call.
ListTopicsOptions	Options for AdminClient.listTopics().
ListTopicsResult	The result of the AdminClient.listTopics() call.
MemberAssignment	A description of the assignments of a specific group member.
MemberDescription	A detailed description of a single group instance in the cluster.
NewPartitions	Describes new partitions for a particular topic in a call to AdminClient.createPartitions(Map).
NewTopic	A new topic to be created via AdminClient.createTopics(Collection).
RecordsToDelete	Describe records to delete in a call to AdminClient.deleteRecords(Map) The API of this class is evolving, see AdminClient for details.
RenewDelegationTokenOptions	Options for AdminClient.renewDelegationToken(byte[], RenewDelegationTokenOptions).
RenewDelegationTokenResult	The result of the KafkaAdminClient.expireDelegationToken(byte[], ExpireDelegationTokenOptions) call.
TopicDescription	A detailed description of a single topic in the cluster.
TopicListing	A listing of a topic in the cluster.

Enum Summary

Enum	Description
AlterConfigOp.OpType
ConfigEntry.ConfigSource	Source of configuration entries.