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.
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.
CreateAclsOptions	Options for AdminClient.createAcls(Collection).
CreateAclsResult	The result of the AdminClient.createAcls(Collection) 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.
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.
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.
KafkaAdminClient	The default implementation of AdminClient.
ListTopicsOptions	Options for AdminClient.listTopics().
ListTopicsResult	The result of the AdminClient.listTopics() call.
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.
TopicDescription	A detailed description of a single topic in the cluster.
TopicListing	A listing of a topic in the cluster.

Enum Summary

Enum	Description
ConfigEntry.ConfigSource	Source of configuration entries.