org.apache.kafka.clients.admin

Class AdminClient

java.lang.Object

org.apache.kafka.clients.admin.AdminClient

All Implemented Interfaces:

java.lang.AutoCloseable

Direct Known Subclasses:

KafkaAdminClient

@InterfaceStability.Evolving
public abstract class AdminClient
extends java.lang.Object
implements java.lang.AutoCloseable

The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs. The minimum broker version required is 0.10.0.0. Methods with stricter requirements will specify the minimum broker version required. This client was introduced in 0.11.0.0 and the API is still evolving. We will try to evolve the API in a compatible manner, but we reserve the right to make breaking changes in minor releases, if necessary. We will update the InterfaceStability annotation and this notice once the API is considered stable.

Constructor Summary

Constructors

Constructor and Description
AdminClient()

Method Summary

Methods

Modifier and Type	Method and Description
AlterConfigsResult	alterConfigs(java.util.Map<ConfigResource,Config> configs) Update the configuration for the specified resources with the default options.
abstract AlterConfigsResult	alterConfigs(java.util.Map<ConfigResource,Config> configs, AlterConfigsOptions options) Update the configuration for the specified resources with the default options.
void	close() Close the AdminClient and release all associated resources.
abstract void	close(long duration, java.util.concurrent.TimeUnit unit) Close the AdminClient and release all associated resources.
static AdminClient	create(java.util.Map<java.lang.String,java.lang.Object> conf) Create a new AdminClient with the given configuration.
static AdminClient	create(java.util.Properties props) Create a new AdminClient with the given configuration.
CreateAclsResult	createAcls(java.util.Collection<AclBinding> acls) Similar to #AdminClient#createAcls(Collection, CreateAclsOptions), but uses the default options.
abstract CreateAclsResult	createAcls(java.util.Collection<AclBinding> acls, CreateAclsOptions options) Creates access control lists (ACLs) which are bound to specific resources.
CreateTopicsResult	createTopics(java.util.Collection<NewTopic> newTopics) Create a batch of new topics with the default options.
abstract CreateTopicsResult	createTopics(java.util.Collection<NewTopic> newTopics, CreateTopicsOptions options) Create a batch of new topics.
DeleteAclsResult	deleteAcls(java.util.Collection<AclBindingFilter> filters) Similar to #AdminClient#deleteAcls(Collection, DeleteAclsOptions), but uses the default options.
abstract DeleteAclsResult	deleteAcls(java.util.Collection<AclBindingFilter> filters, DeleteAclsOptions options) Deletes access control lists (ACLs) according to the supplied filters.
DeleteTopicsResult	deleteTopics(java.util.Collection<java.lang.String> topics) Similar to #AdminClient#deleteTopics(Collection, DeleteTopicsOptions), but uses the default options.
abstract DeleteTopicsResult	deleteTopics(java.util.Collection<java.lang.String> topics, DeleteTopicsOptions options) Delete a batch of topics.
DescribeAclsResult	describeAcls(AclBindingFilter filter) Similar to #describeAcls(AclBindingFilter, DescribeAclsOptions), but uses the default options.
abstract DescribeAclsResult	describeAcls(AclBindingFilter filter, DescribeAclsOptions options) Lists access control lists (ACLs) according to the supplied filter.
DescribeClusterResult	describeCluster() Get information about the nodes in the cluster, using the default options.
abstract DescribeClusterResult	describeCluster(DescribeClusterOptions options) Get information about the nodes in the cluster.
DescribeConfigsResult	describeConfigs(java.util.Collection<ConfigResource> resources) Get the configuration for the specified resources with the default options.
abstract DescribeConfigsResult	describeConfigs(java.util.Collection<ConfigResource> resources, DescribeConfigsOptions options) Get the configuration for the specified resources.
DescribeTopicsResult	describeTopics(java.util.Collection<java.lang.String> topicNames) Describe some topics in the cluster, with the default options.
abstract DescribeTopicsResult	describeTopics(java.util.Collection<java.lang.String> topicNames, DescribeTopicsOptions options) Describe some topics in the cluster.
ListTopicsResult	listTopics() List the topics available in the cluster with the default options.
abstract ListTopicsResult	listTopics(ListTopicsOptions options) List the topics available in the cluster.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdminClient

public AdminClient()

Method Detail

create

public static AdminClient create(java.util.Properties props)

Create a new AdminClient with the given configuration.

Parameters:

props - The configuration.

Returns:

The new KafkaAdminClient.

create

public static AdminClient create(java.util.Map<java.lang.String,java.lang.Object> conf)

Create a new AdminClient with the given configuration.

Parameters:

conf - The configuration.

Returns:

The new KafkaAdminClient.

close

public void close()

Close the AdminClient and release all associated resources. See close(long, TimeUnit)

Specified by:

close in interface java.lang.AutoCloseable

close

public abstract void close(long duration,
         java.util.concurrent.TimeUnit unit)

Close the AdminClient and release all associated resources. The close operation has a grace period during which current operations will be allowed to complete, specified by the given duration and time unit. New operations will not be accepted during the grace period. Once the grace period is over, all operations that have not yet been completed will be aborted with a TimeoutException.

Parameters:

duration - The duration to use for the wait time.

unit - The time unit to use for the wait time.

createTopics

public CreateTopicsResult createTopics(java.util.Collection<NewTopic> newTopics)

Create a batch of new topics with the default options. This operation is supported by brokers with version 0.10.1.0 or higher.

Parameters:

newTopics - The new topics to create.

Returns:

The CreateTopicsResult.

createTopics

public abstract CreateTopicsResult createTopics(java.util.Collection<NewTopic> newTopics,
                              CreateTopicsOptions options)

Create a batch of new topics. It may take several seconds after AdminClient#createTopics returns success for all the brokers to become aware that the topics have been created. During this time, AdminClient#listTopics and AdminClient#describeTopics may not return information about the new topics. This operation is supported by brokers with version 0.10.1.0 or higher. The validateOnly option is supported from version 0.10.2.0.

Parameters:

newTopics - The new topics to create.

options - The options to use when creating the new topics.

Returns:

The CreateTopicsResult.

deleteTopics

public DeleteTopicsResult deleteTopics(java.util.Collection<java.lang.String> topics)

Similar to #AdminClient#deleteTopics(Collection, DeleteTopicsOptions), but uses the default options. This operation is supported by brokers with version 0.10.1.0 or higher.

Parameters:

topics - The topic names to delete.

Returns:

The DeleteTopicsResult.

deleteTopics

public abstract DeleteTopicsResult deleteTopics(java.util.Collection<java.lang.String> topics,
                              DeleteTopicsOptions options)

Delete a batch of topics. It may take several seconds after AdminClient#deleteTopics returns success for all the brokers to become aware that the topics are gone. During this time, AdminClient#listTopics and AdminClient#describeTopics may continue to return information about the deleted topics. If delete.topic.enable is false on the brokers, deleteTopics will mark the topics for deletion, but not actually delete them. The futures will return successfully in this case. This operation is supported by brokers with version 0.10.1.0 or higher.

Parameters:

topics - The topic names to delete.

options - The options to use when deleting the topics.

Returns:

The DeleteTopicsResult.

listTopics

public ListTopicsResult listTopics()

List the topics available in the cluster with the default options.

Returns:

The ListTopicsResult.

listTopics

public abstract ListTopicsResult listTopics(ListTopicsOptions options)

List the topics available in the cluster.

Parameters:

options - The options to use when listing the topics.

Returns:

The ListTopicsResult.

describeTopics

public DescribeTopicsResult describeTopics(java.util.Collection<java.lang.String> topicNames)

Describe some topics in the cluster, with the default options. See AdminClient#describeTopics(Collection, DescribeTopicsOptions)

Parameters:

topicNames - The names of the topics to describe.

Returns:

The DescribeTopicsResult.

describeTopics

public abstract DescribeTopicsResult describeTopics(java.util.Collection<java.lang.String> topicNames,
                                  DescribeTopicsOptions options)

Describe some topics in the cluster.

Parameters:

topicNames - The names of the topics to describe.

options - The options to use when describing the topic.

Returns:

The DescribeTopicsResult.

describeCluster

public DescribeClusterResult describeCluster()

Get information about the nodes in the cluster, using the default options.

Returns:

The DescribeClusterResult.

describeCluster

public abstract DescribeClusterResult describeCluster(DescribeClusterOptions options)

Get information about the nodes in the cluster.

Parameters:

options - The options to use when getting information about the cluster.

Returns:

The DescribeClusterResult.

describeAcls

public DescribeAclsResult describeAcls(AclBindingFilter filter)

Similar to #describeAcls(AclBindingFilter, DescribeAclsOptions), but uses the default options. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

filter - The filter to use.

Returns:

The DeleteAclsResult.

describeAcls

public abstract DescribeAclsResult describeAcls(AclBindingFilter filter,
                              DescribeAclsOptions options)

Lists access control lists (ACLs) according to the supplied filter. Note: it may take some time for changes made by createAcls or deleteAcls to be reflected in the output of describeAcls. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

filter - The filter to use.

options - The options to use when listing the ACLs.

Returns:

The DeleteAclsResult.

createAcls

public CreateAclsResult createAcls(java.util.Collection<AclBinding> acls)

Similar to #AdminClient#createAcls(Collection, CreateAclsOptions), but uses the default options. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

acls - The ACLs to create

Returns:

The CreateAclsResult.

createAcls

public abstract CreateAclsResult createAcls(java.util.Collection<AclBinding> acls,
                          CreateAclsOptions options)

Creates access control lists (ACLs) which are bound to specific resources. If you attempt to add an ACL that duplicates an existing ACL, no error will be raised, but no changes will be made. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

acls - The ACLs to create

options - The options to use when creating the ACLs.

Returns:

The CreateAclsResult.

deleteAcls

public DeleteAclsResult deleteAcls(java.util.Collection<AclBindingFilter> filters)

Similar to #AdminClient#deleteAcls(Collection, DeleteAclsOptions), but uses the default options. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

filters - The filters to use.

Returns:

The DeleteAclsResult.

deleteAcls

public abstract DeleteAclsResult deleteAcls(java.util.Collection<AclBindingFilter> filters,
                          DeleteAclsOptions options)

Deletes access control lists (ACLs) according to the supplied filters. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

filters - The filters to use.

options - The options to use when deleting the ACLs.

Returns:

The DeleteAclsResult.

describeConfigs

public DescribeConfigsResult describeConfigs(java.util.Collection<ConfigResource> resources)

Get the configuration for the specified resources with the default options. See describeConfigs(Collection, DescribeConfigsOptions) for more details. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

resources - The resources (topic and broker resource types are currently supported)

Returns:

The DescribeConfigsResult

describeConfigs

public abstract DescribeConfigsResult describeConfigs(java.util.Collection<ConfigResource> resources,
                                    DescribeConfigsOptions options)

Get the configuration for the specified resources. The returned configuration includes default values and the isDefault() method can be used to distinguish them from user supplied values. The value of config entries where isSensitive() is true is always null so that sensitive information is not disclosed. Config entries where isReadOnly() is true cannot be updated. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

resources - The resources (topic and broker resource types are currently supported)

options - The options to use when describing configs

Returns:

The DescribeConfigsResult

alterConfigs

public AlterConfigsResult alterConfigs(java.util.Map<ConfigResource,Config> configs)

Update the configuration for the specified resources with the default options. See alterConfigs(Map, AlterConfigsOptions) for more details. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

configs - The resources with their configs (topic is the only resource type with configs that can be updated currently)

Returns:

The AlterConfigsResult

alterConfigs

public abstract AlterConfigsResult alterConfigs(java.util.Map<ConfigResource,Config> configs,
                              AlterConfigsOptions options)

Update the configuration for the specified resources with the default options. Updates are not transactional so they may succeed for some resources while fail for others. The configs for a particular resource are updated atomically. This operation is supported by brokers with version 0.11.0.0 or higher.

Parameters:

configs - The resources with their configs (topic is the only resource type with configs that can be updated currently)

options - The options to use when describing configs

Returns:

The AlterConfigsResult