Class AdminClient
java.lang.Object
org.apache.kafka.clients.admin.AdminClient
- All Implemented Interfaces:
AutoCloseable,Admin
- Direct Known Subclasses:
KafkaAdminClient
Constructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionstatic AdminClientCreate a new Admin with the given configuration.static AdminClientcreate(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, waitMethods 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
Create a new Admin with the given configuration.- Parameters:
props- The configuration.- Returns:
- The new KafkaAdminClient.
create
Create a new Admin with the given configuration.- Parameters:
conf- The configuration.- Returns:
- The new KafkaAdminClient.