Package org.apache.kafka.clients.admin
Class AdminClient
- java.lang.Object
-
- org.apache.kafka.clients.admin.AdminClient
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,Admin
- Direct Known Subclasses:
KafkaAdminClient
public abstract class AdminClient extends java.lang.Object implements Admin
The base class for in-built admin clients. Client code should use the newerAdmin
interface in preference to this class. This class may be removed in a later release, but has not be marked as deprecated to avoid unnecessary noise.
-
-
Constructor Summary
Constructors Constructor Description AdminClient()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static AdminClient
create(java.util.Map<java.lang.String,java.lang.Object> conf)
Create a new Admin with the given configuration.static AdminClient
create(java.util.Properties props)
Create a new Admin with the given configuration.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.clients.admin.Admin
alterClientQuotas, alterClientQuotas, alterConfigs, alterConfigs, alterConsumerGroupOffsets, alterConsumerGroupOffsets, alterPartitionReassignments, alterPartitionReassignments, alterReplicaLogDirs, alterReplicaLogDirs, close, close, close, createAcls, createAcls, createDelegationToken, createDelegationToken, createPartitions, createPartitions, createTopics, createTopics, deleteAcls, deleteAcls, deleteConsumerGroupOffsets, deleteConsumerGroupOffsets, deleteConsumerGroups, deleteConsumerGroups, deleteRecords, deleteRecords, deleteTopics, deleteTopics, describeAcls, describeAcls, describeClientQuotas, describeClientQuotas, describeCluster, describeCluster, describeConfigs, describeConfigs, describeConsumerGroups, describeConsumerGroups, describeDelegationToken, describeDelegationToken, describeLogDirs, describeLogDirs, describeReplicaLogDirs, describeReplicaLogDirs, describeTopics, describeTopics, electLeaders, electLeaders, electPreferredLeaders, electPreferredLeaders, expireDelegationToken, expireDelegationToken, incrementalAlterConfigs, incrementalAlterConfigs, listConsumerGroupOffsets, listConsumerGroupOffsets, listConsumerGroups, listConsumerGroups, listOffsets, listOffsets, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listPartitionReassignments, listTopics, listTopics, listTopics, listTopics, metrics, removeMembersFromConsumerGroup, renewDelegationToken, renewDelegationToken
-
-
-
-
Method Detail
-
create
public static AdminClient create(java.util.Properties props)
Create a new Admin 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 Admin with the given configuration.- Parameters:
conf
- The configuration.- Returns:
- The new KafkaAdminClient.
-
-