org.apache.kafka.clients.admin

Interface ConfluentAdmin

All Superinterfaces:

Admin, java.lang.AutoCloseable

All Known Implementing Classes:

KafkaAdminClient

@Confluent
public interface ConfluentAdmin
extends Admin

This interface contains admin client methods that:

1. are only present in Confluent Server, or
2. existing Admin methods that return or take extra information only available in Confluent Server.

Any new or update to admin client api that need these features should be done here.

Method Summary

Modifier and Type	Method and Description
AlterMirrorsResult	alterMirrors(java.util.List<org.apache.kafka.common.requests.AlterMirrorsRequest.Op> ops, AlterMirrorsOptions options) Performs a state alteration for topic mirroring.
static ConfluentAdmin	create(java.util.Map<java.lang.String,java.lang.Object> conf) Create a new ConfluentAdmin with the given configuration.
static ConfluentAdmin	create(java.util.Properties props) Create a new ConfluentAdmin with the given configuration.
CreateAclsResult	createCentralizedAcls(java.util.Collection<AclBinding> acls, CreateAclsOptions options, java.lang.String clusterId, int writerBrokerId) Creates access control lists (ACLs) which are bound to specific resources.
CreateClusterLinksResult	createClusterLinks(java.util.Collection<org.apache.kafka.common.requests.NewClusterLink> clusterLinks, CreateClusterLinksOptions options) Creates links to remote clusters with the specified configurations for performing inter-cluster communications.
DeleteAclsResult	deleteCentralizedAcls(java.util.Collection<AclBindingFilter> filters, DeleteAclsOptions options, java.lang.String clusterId, int writerBrokerId) Deletes access control lists (ACLs) according to the supplied filters.
DeleteClusterLinksResult	deleteClusterLinks(java.util.Collection<java.lang.String> linkNames, DeleteClusterLinksOptions options) Deletes established links to remote clusters with the provided link names.
default DescribeBrokerRemovalsResult	describeBrokerRemovals() Describes all the broker removals in the cluster.
DescribeBrokerRemovalsResult	describeBrokerRemovals(DescribeBrokerRemovalsOptions options) Describes all the broker removals in the cluster.
ListClusterLinksResult	listClusterLinks(ListClusterLinksOptions options) Lists the cluster links.
default RemoveBrokersResult	removeBrokers(java.util.List<java.lang.Integer> brokersToRemove) Drain data off a given set of brokers and remove them from the cluster via shutdown.
RemoveBrokersResult	removeBrokers(java.util.List<java.lang.Integer> brokersToRemove, RemoveBrokersOptions options) Drain data off a given set of brokers and remove them from the cluster via shutdown.
ReplicaStatusResult	replicaStatus(java.util.Set<TopicPartition> partitions, ReplicaStatusOptions options) Retrieves the status of the replicas for a set of partitions, including observers.
WriteTxnMarkerResult	writeTransactionMarkers(WriteTxnMarkerSpec spec, java.util.Set<TopicPartition> partitions) Send transaction markers to a partition.

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, metrics, removeMembersFromConsumerGroup, renewDelegationToken, renewDelegationToken

Method Detail

create

static ConfluentAdmin create(java.util.Properties props)

Create a new ConfluentAdmin with the given configuration.

Specified by:

create in interface Admin

Parameters:

props - The configuration.

Returns:

The new KafkaAdminClient.

create

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

Create a new ConfluentAdmin with the given configuration.

Specified by:

create in interface Admin

Parameters:

conf - The configuration.

Returns:

The new KafkaAdminClient.

replicaStatus

@Confluent
ReplicaStatusResult replicaStatus(java.util.Set<TopicPartition> partitions,
                                             ReplicaStatusOptions options)

Retrieves the status of the replicas for a set of partitions, including observers.

The status of the replicas will be as witnessed by the partition leader. That is, the replicas themselves may be further in progress than what's provided, however the leader has not yet processed that state update.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned ReplicaStatusResult:

• TopicAuthorizationException If the authenticated user didn't have describe access to the Topic.
• UnknownTopicOrPartitionException If a given topic or partition does not exist.
• NotLeaderOrFollowerException If the partition leader changed while the request was outstanding.
• TimeoutException If the request timed out before the controller could retrieve the partition's replica status.

Parameters:

partitions - The partitions to retrieve replica status for.

options - The options to use.

Returns:

The resulting replica status of every requested partition.

createCentralizedAcls

@Confluent
CreateAclsResult createCentralizedAcls(java.util.Collection<AclBinding> acls,
                                                  CreateAclsOptions options,
                                                  java.lang.String clusterId,
                                                  int writerBrokerId)

Creates access control lists (ACLs) which are bound to specific resources.

This operation is not transactional so it may succeed for some ACLs while fail for others.

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.

clusterId - Cluster id for which ACLs are being updated

writerBrokerId - Broker id of the current centralized metadata master writer

Returns:

The CreateAclsResult.

deleteCentralizedAcls

@Confluent
DeleteAclsResult deleteCentralizedAcls(java.util.Collection<AclBindingFilter> filters,
                                                  DeleteAclsOptions options,
                                                  java.lang.String clusterId,
                                                  int writerBrokerId)

Deletes access control lists (ACLs) according to the supplied filters.

This operation is not transactional so it may succeed for some ACLs while fail for others.

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.

clusterId - Cluster id for which ACLs are being updated

writerBrokerId - Broker id of the current centralized metadata master writer

Returns:

The DeleteAclsResult.

removeBrokers

@Confluent
default RemoveBrokersResult removeBrokers(java.util.List<java.lang.Integer> brokersToRemove)

Drain data off a given set of brokers and remove them from the cluster via shutdown. This API initiates the removal. It is suggested that the user tracks it via describeBrokerRemovals() Once initiated, the brokers will be shut down and replicas will be reassigned away from them.

This is a convenience method for removeBrokers(List, RemoveBrokersOptions) with default options. See the overload for more details.

Parameters:

brokersToRemove - The broker IDs to drain off partition replicas and shut down. Must not be empty.

Returns:

The result of the broker removal operation.

removeBrokers

@Confluent
RemoveBrokersResult removeBrokers(java.util.List<java.lang.Integer> brokersToRemove,
                                             RemoveBrokersOptions options)

Drain data off a given set of brokers and remove them from the cluster via shutdown. This API initiates the removal. It is suggested that the user tracks it via describeBrokerRemovals() Once initiated, the brokers will be shut down and replicas will be reassigned away from them.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned RemoveBrokersResult:

ClusterAuthorizationException If we didn't have sufficient permission to initiate the broker removal. None of the requests started. TimeoutException If the request timed out before the controller could initiate the broker removal. It cannot be guaranteed whether the removal was initiated or not. BalancerOfflineException If the Confluent Balancer component is disabled or not started yet. BalancerOperationFailedException If the operation failed during execution of the removal. InsufficientRebalancePlanMetricsException If computing the rebalance plan for broker removal failed due to insufficient metrics. RebalancePlanComputationException If computing the rebalance plan for broker removal failed for reasons other than insufficient metrics like not enough disk space, replication factor same as the cluster size in case of broker removal etc. InvalidBrokerRemovalException If requested broker removal operation is invalid, examples being a non-existent broker ID or some partitions (RF=1) becoming unavailable as a result of the removal. BrokerRemovalInProgressException If the broker is already being removed. BrokerRemovedException If the broker was already removed successfully.

Parameters:

brokersToRemove - The broker IDs to drain off partition replicas and shut down. Must not be empty.

options - The options to use for the request.

Returns:

The result of the broker removal operation.

describeBrokerRemovals

@Confluent
default DescribeBrokerRemovalsResult describeBrokerRemovals()

Describes all the broker removals in the cluster. Note that a removal is considered cleared once a broker starts up with 0 partitions. This is a convenience method for describeBrokerRemovals(DescribeBrokerRemovalsOptions) with default options. See the overload for more details.

describeBrokerRemovals

@Confluent
DescribeBrokerRemovalsResult describeBrokerRemovals(DescribeBrokerRemovalsOptions options)

Describes all the broker removals in the cluster. Note that a removal is considered cleared once a broker starts up with 0 partitions. A broker removal consists of broker shutdown and partition reassignments that move all replicas the now-shutdown broker hosted away from it. The status of the removal is tracked by two separate status fields: 1. #BrokerRemovalDescription.brokerShutdownStatus(), a #BrokerRemovalDescription.BrokerShutdownStatus denoting the status of the shutdown operation 2. #BrokerRemovalDescription.partitionReassignmentsStatus(), a #BrokerRemovalDescription.PartitionReassignmentsStatus denoting the status of the partition reassignments operation When at least one of the two has a failed status, the broker removal operation is considered failed. The user is expected to retry the removal via #removeBrokers(List). When both have a completed status, the broker removal operation is considered a success.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned DescribeBrokerRemovalsResult:

• ClusterAuthorizationException If the authenticated user didn't have DESCRIBE access to the cluster.
• TimeoutException If the request timed out before the controller could describe the removals.

Parameters:

options - The options to use when describing the broker removals.

Returns:

The DescribeBrokerRemovalResult.

createClusterLinks

@Confluent
CreateClusterLinksResult createClusterLinks(java.util.Collection<org.apache.kafka.common.requests.NewClusterLink> clusterLinks,
                                                       CreateClusterLinksOptions options)

Creates links to remote clusters with the specified configurations for performing inter-cluster communications. Once established, the cluster links can referenced by their link names for issuing requests. The following exceptions can be anticipated when calling get() on the futures obtained from the returned createClusterLinksResult:

• InvalidClusterLinkException If the cluster link name is illegal.
• ClusterAuthorizationException If the authenticated user didn't have CREATE access to the cluster.
• ClusterLinkExistsException If a cluster link already exists for the provided link name.
• TimeoutException If the request timed out before the controller could create the cluster link.

Parameters:

clusterLinks - The cluster links to create.

options - The options to use when creating the cluster links.

Returns:

The CreateClusterLinksResult.

listClusterLinks

@Confluent
ListClusterLinksResult listClusterLinks(ListClusterLinksOptions options)

Lists the cluster links.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned listClusterLinksResult:

• ClusterAuthorizationException If the authenticated user didn't have DESCRIBE_CONFIGS access to the cluster.
• TimeoutException If the request timed out before the controller could list the cluster links.

Parameters:

options - The options to use when listing the cluster links.

Returns:

The ListClusterLinksResult.

deleteClusterLinks

@Confluent
DeleteClusterLinksResult deleteClusterLinks(java.util.Collection<java.lang.String> linkNames,
                                                       DeleteClusterLinksOptions options)

Deletes established links to remote clusters with the provided link names.

Deleting a cluster link does not affect the cluster link's data in any way.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned deleteClusterLinksResult:

• InvalidClusterLinkException If the cluster link name is illegal.
• ClusterAuthorizationException If the authenticated user didn't have DELETE access to the cluster.
• ClusterLinkNotFoundException If the cluster link to delete doesn't exist.
• TimeoutException If the request timed out before the controller could delete the cluster link.

Parameters:

linkNames - The names of the cluster links to delete.

options - The options to use when deleting the cluster links.

Returns:

The DeleteClusterLinksResult.

alterMirrors

@Confluent
AlterMirrorsResult alterMirrors(java.util.List<org.apache.kafka.common.requests.AlterMirrorsRequest.Op> ops,
                                           AlterMirrorsOptions options)

Performs a state alteration for topic mirroring.

The future of the individual alter mirror ops should be used for obtaining the result.

The following exceptions can be anticipated when calling get() on the futures obtained from the returned alterMirrorsResult:

• ClusterAuthorizationException If the authenticated user didn't have ALTER access to the cluster.
• TimeoutException If the request timed out before the controller could complete the mirror operation.

Parameters:

ops - The mirror alteration operations.

options - The options to use when controlling mirrors.

Returns:

The AlterMirrorsResult.

writeTransactionMarkers

@Confluent
WriteTxnMarkerResult writeTransactionMarkers(WriteTxnMarkerSpec spec,
                                                        java.util.Set<TopicPartition> partitions)

Send transaction markers to a partition. Can be used to clear a transaction that is left dangling. Only use this if you know what you're doing.