Class AdminClient

java.lang.Object

org.apache.kafka.clients.admin.AdminClient

All Implemented Interfaces:

AutoCloseable, Admin

Direct Known Subclasses:

KafkaAdminClient

public abstract class AdminClient
extends Object
implements Admin

The base class for in-built admin clients. Client code should use the newer Admin interface in preference to this class. This class may be removed in a later release, but has not been marked as deprecated to avoid unnecessary noise.

Constructor Summary

Constructors

Constructor	Description
AdminClient()

Method Summary

Modifier and Type	Method	Description
static AdminClient	create(Map<String,Object> conf)	Create a new Admin with the given configuration.
static AdminClient	create(Properties props)	Create a new Admin with the given configuration.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.clients.admin.Admin

abortTransaction, abortTransaction, addRaftVoter, addRaftVoter, alterClientQuotas, alterClientQuotas, alterConsumerGroupOffsets, alterConsumerGroupOffsets, alterPartitionReassignments, alterPartitionReassignments, alterReplicaLogDirs, alterReplicaLogDirs, alterShareGroupOffsets, alterShareGroupOffsets, alterStreamsGroupOffsets, alterStreamsGroupOffsets, alterUserScramCredentials, alterUserScramCredentials, clientInstanceId, close, close, createAcls, createAcls, createDelegationToken, createDelegationToken, createPartitions, createPartitions, createTopics, createTopics, deleteAcls, deleteAcls, deleteConsumerGroupOffsets, deleteConsumerGroupOffsets, deleteConsumerGroups, deleteConsumerGroups, deleteRecords, deleteRecords, deleteShareGroupOffsets, deleteShareGroupOffsets, deleteShareGroups, deleteShareGroups, deleteStreamsGroupOffsets, deleteStreamsGroupOffsets, deleteStreamsGroups, deleteStreamsGroups, deleteTopics, deleteTopics, deleteTopics, deleteTopics, describeAcls, describeAcls, describeClassicGroups, describeClassicGroups, describeClientQuotas, describeClientQuotas, describeCluster, describeCluster, describeConfigs, describeConfigs, describeConsumerGroups, describeConsumerGroups, describeDelegationToken, describeDelegationToken, describeFeatures, describeFeatures, describeLogDirs, describeLogDirs, describeMetadataQuorum, describeMetadataQuorum, describeProducers, describeProducers, describeReplicaLogDirs, describeReplicaLogDirs, describeShareGroups, describeShareGroups, describeStreamsGroups, describeStreamsGroups, describeTopics, describeTopics, describeTopics, describeTopics, describeTransactions, describeTransactions, describeUserScramCredentials, describeUserScramCredentials, describeUserScramCredentials, electLeaders, electLeaders, expireDelegationToken, expireDelegationToken, fenceProducers, fenceProducers, forceTerminateTransaction, forceTerminateTransaction, incrementalAlterConfigs, incrementalAlterConfigs, listClientMetricsResources, listClientMetricsResources, listConfigResources, listConfigResources, listConsumerGroupOffsets, listConsumerGroupOffsets, listConsumerGroupOffsets, listConsumerGroupOffsets, listConsumerGroups, listConsumerGroups, listGroups, listGroups, listOffsets, listOffsets, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listShareGroupOffsets, listShareGroupOffsets, listStreamsGroupOffsets, listStreamsGroupOffsets, listTopics, listTopics, listTransactions, listTransactions, metrics, registerMetricForSubscription, removeMembersFromConsumerGroup, removeRaftVoter, removeRaftVoter, renewDelegationToken, renewDelegationToken, unregisterBroker, unregisterBroker, unregisterMetricFromSubscription, updateFeatures

Constructor Details

AdminClient

public AdminClient()

Method Details

create

public static AdminClient create(Properties props)

Create a new Admin with the given configuration.

Parameters:

props - The configuration.

Returns:

The new KafkaAdminClient.

create

public static AdminClient create(Map<String,Object> conf)

Create a new Admin with the given configuration.

Parameters:

conf - The configuration.

Returns:

The new KafkaAdminClient.