alterReplicaLogDirs
|
AlterReplicaLogDirsResult alterReplicaLogDirs(
Map<TopicPartitionReplica, String> replicaAssignment,
AlterReplicaLogDirsOptions options)
|
close
|
void close(
Duration timeout)
|
createAcls
|
CreateAclsResult createAcls(
Collection<AclBinding> acls,
CreateAclsOptions options)
|
createDelegationToken
|
CreateDelegationTokenResult createDelegationToken(
CreateDelegationTokenOptions options)
|
createPartitions
|
CreatePartitionsResult createPartitions(
Map<String, NewPartitions> newPartitions,
CreatePartitionsOptions options)
|
createTopics
|
CreateTopicsResult createTopics(
Collection<NewTopic> newTopics,
CreateTopicsOptions options)
|
deleteAcls
|
DeleteAclsResult deleteAcls(
Collection<AclBindingFilter> filters,
DeleteAclsOptions options)
|
deleteConsumerGroups
|
DeleteConsumerGroupsResult deleteConsumerGroups(
Collection<String> groupIds,
DeleteConsumerGroupsOptions options)
|
deleteRecords
|
DeleteRecordsResult deleteRecords(
Map<TopicPartition, RecordsToDelete> recordsToDelete,
DeleteRecordsOptions options)
|
deleteTopics
|
DeleteTopicsResult deleteTopics(
Collection<String> topics,
DeleteTopicsOptions options)
|
describeAcls
|
DescribeAclsResult describeAcls(
AclBindingFilter filter,
DescribeAclsOptions options)
|
describeCluster
|
DescribeClusterResult describeCluster(
DescribeClusterOptions options)
|
describeConfigs
|
DescribeConfigsResult describeConfigs(
Collection<ConfigResource> resources,
DescribeConfigsOptions options)
|
describeConsumerGroups
|
DescribeConsumerGroupsResult describeConsumerGroups(
Collection<String> groupIds,
DescribeConsumerGroupsOptions options)
|
describeDelegationToken
|
DescribeDelegationTokenResult describeDelegationToken(
DescribeDelegationTokenOptions options)
|
describeLogDirs
|
DescribeLogDirsResult describeLogDirs(
Collection<Integer> brokers,
DescribeLogDirsOptions options)
|
describeReplicaLogDirs
|
DescribeReplicaLogDirsResult describeReplicaLogDirs(
Collection<TopicPartitionReplica> replicas,
DescribeReplicaLogDirsOptions options)
|
describeTopics
|
DescribeTopicsResult describeTopics(
Collection<String> topicNames,
DescribeTopicsOptions options)
|
electPreferredLeaders
|
ElectPreferredLeadersResult electPreferredLeaders(
Collection<TopicPartition> partitions,
ElectPreferredLeadersOptions options)
ElectPreferredLeadersResult electPreferredLeaders(
Collection<TopicPartition> partitions) (1)
-
Uses the default ElectPreferredLeadersOptions
|
expireDelegationToken
|
ExpireDelegationTokenResult expireDelegationToken(
byte[] hmac,
ExpireDelegationTokenOptions options)
|
incrementalAlterConfigs
|
AlterConfigsResult incrementalAlterConfigs(
Map<ConfigResource,
Collection<AlterConfigOp>> configs,
AlterConfigsOptions options)
|
listConsumerGroupOffsets
|
ListConsumerGroupOffsetsResult listConsumerGroupOffsets(
String groupId,
ListConsumerGroupOffsetsOptions options)
|
listConsumerGroups
|
ListConsumerGroupsResult listConsumerGroups(
ListConsumerGroupsOptions options)
|
listTopics
|
ListTopicsResult listTopics(
ListTopicsOptions options)
|
metrics
|
Map<MetricName, ? extends Metric> metrics()
|
renewDelegationToken
|
RenewDelegationTokenResult renewDelegationToken(
byte[] hmac,
RenewDelegationTokenOptions options)
|