Interface IAdmin
.NET interface for TO BE DEFINED FROM USER
public interface IAdmin : IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, IAutoCloseable
- Inherited Members
-
IJVMBridgeBase.MonitorEnter()IJVMBridgeBase.MonitorExit()IJVMBridgeBase.IsInstanceOf(IJavaType)IJVMBridgeBase.IsInstanceOf<T>()IJVMBridgeBase.RuntimeIsInstanceOf<T>()IJVMBridgeBase.CastTo<TNewClass>()IJVMBridgeBase.CastDirect<TNewClass>()IJVMBridgeBase.DynBridgeInstanceIJVMBridgeBase.BridgeInstanceIJVMBridgeDefinition.BridgeClassNameIJVMBridgeDefinition.IsBridgeInterfaceIJVMBridgeDefinition.IsBridgeAbstractIJVMBridgeDefinition.IsBridgeStaticIJVMBridgeDefinition.IsBridgeCloseableIJVMBridgeDefinition.IsBridgeListener
- Extension Methods
Methods
AbortTransaction(AbortTransactionSpec)
AbortTransactionResult AbortTransaction(AbortTransactionSpec spec)
Parameters
spec
AbortTransactionSpec
Returns
AbortTransaction(AbortTransactionSpec, AbortTransactionOptions)
AbortTransactionResult AbortTransaction(AbortTransactionSpec spec, AbortTransactionOptions options)
Parameters
spec
AbortTransactionSpecoptions
AbortTransactionOptions
Returns
AlterClientQuotas(Collection<ClientQuotaAlteration>)
AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> entries)
Parameters
entries
Collection<ClientQuotaAlteration>
Returns
AlterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)
AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> entries, AlterClientQuotasOptions options)
Parameters
entries
Collection<ClientQuotaAlteration>options
AlterClientQuotasOptions
Returns
AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>)
AlterConsumerGroupOffsetsResult AlterConsumerGroupOffsets(String groupId, Map<TopicPartition, OffsetAndMetadata> offsets)
Parameters
groupId
Stringoffsets
Map<TopicPartition, OffsetAndMetadata>
Returns
AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions)
AlterConsumerGroupOffsetsResult AlterConsumerGroupOffsets(String groupId, Map<TopicPartition, OffsetAndMetadata> offsets, AlterConsumerGroupOffsetsOptions options)
Parameters
groupId
Stringoffsets
Map<TopicPartition, OffsetAndMetadata>options
AlterConsumerGroupOffsetsOptions
Returns
AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>)
AlterPartitionReassignmentsResult AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>> reassignments)
Parameters
reassignments
Map<TopicPartition, Optional<NewPartitionReassignment>>
Returns
AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions)
AlterPartitionReassignmentsResult AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>> reassignments, AlterPartitionReassignmentsOptions options)
Parameters
reassignments
Map<TopicPartition, Optional<NewPartitionReassignment>>options
AlterPartitionReassignmentsOptions
Returns
AlterReplicaLogDirs(Map<TopicPartitionReplica, String>)
AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> replicaAssignment)
Parameters
replicaAssignment
Map<TopicPartitionReplica, String>
Returns
AlterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)
AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> replicaAssignment, AlterReplicaLogDirsOptions options)
Parameters
replicaAssignment
Map<TopicPartitionReplica, String>options
AlterReplicaLogDirsOptions
Returns
AlterUserScramCredentials(List<UserScramCredentialAlteration>)
AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> alterations)
Parameters
alterations
List<UserScramCredentialAlteration>
Returns
AlterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)
AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> alterations, AlterUserScramCredentialsOptions options)
Parameters
alterations
List<UserScramCredentialAlteration>options
AlterUserScramCredentialsOptions
Returns
Close()
void Close()
Close(Duration)
void Close(Duration timeout)
Parameters
timeout
Duration
CreateAcls(Collection<AclBinding>)
CreateAclsResult CreateAcls(Collection<AclBinding> acls)
Parameters
acls
Collection<AclBinding>
Returns
CreateAcls(Collection<AclBinding>, CreateAclsOptions)
CreateAclsResult CreateAcls(Collection<AclBinding> acls, CreateAclsOptions options)
Parameters
acls
Collection<AclBinding>options
CreateAclsOptions
Returns
CreateDelegationToken()
CreateDelegationTokenResult CreateDelegationToken()
Returns
CreateDelegationToken(CreateDelegationTokenOptions)
CreateDelegationTokenResult CreateDelegationToken(CreateDelegationTokenOptions options)
Parameters
options
CreateDelegationTokenOptions
Returns
CreatePartitions(Map<String, NewPartitions>)
CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> newPartitions)
Parameters
newPartitions
Map<String, NewPartitions>
Returns
CreatePartitions(Map<String, NewPartitions>, CreatePartitionsOptions)
CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> newPartitions, CreatePartitionsOptions options)
Parameters
newPartitions
Map<String, NewPartitions>options
CreatePartitionsOptions
Returns
CreateTopics(Collection<NewTopic>)
CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics)
Parameters
newTopics
Collection<NewTopic>
Returns
CreateTopics(Collection<NewTopic>, CreateTopicsOptions)
CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics, CreateTopicsOptions options)
Parameters
newTopics
Collection<NewTopic>options
CreateTopicsOptions
Returns
DeleteAcls(Collection<AclBindingFilter>)
DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> filters)
Parameters
filters
Collection<AclBindingFilter>
Returns
DeleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)
DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> filters, DeleteAclsOptions options)
Parameters
filters
Collection<AclBindingFilter>options
DeleteAclsOptions
Returns
DeleteConsumerGroupOffsets(String, Set<TopicPartition>)
DeleteConsumerGroupOffsetsResult DeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)
Parameters
groupId
Stringpartitions
Set<TopicPartition>
Returns
DeleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)
DeleteConsumerGroupOffsetsResult DeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, DeleteConsumerGroupOffsetsOptions options)
Parameters
groupId
Stringpartitions
Set<TopicPartition>options
DeleteConsumerGroupOffsetsOptions
Returns
DeleteConsumerGroups(Collection<String>)
DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> groupIds)
Parameters
groupIds
Collection<String>
Returns
DeleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions)
DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> groupIds, DeleteConsumerGroupsOptions options)
Parameters
groupIds
Collection<String>options
DeleteConsumerGroupsOptions
Returns
DeleteRecords(Map<TopicPartition, RecordsToDelete>)
DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete)
Parameters
recordsToDelete
Map<TopicPartition, RecordsToDelete>
Returns
DeleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)
DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete, DeleteRecordsOptions options)
Parameters
recordsToDelete
Map<TopicPartition, RecordsToDelete>options
DeleteRecordsOptions
Returns
DeleteTopics(Collection<String>)
DeleteTopicsResult DeleteTopics(Collection<String> topics)
Parameters
topics
Collection<String>
Returns
DeleteTopics(Collection<String>, DeleteTopicsOptions)
DeleteTopicsResult DeleteTopics(Collection<String> topics, DeleteTopicsOptions options)
Parameters
topics
Collection<String>options
DeleteTopicsOptions
Returns
DeleteTopics(TopicCollection)
DeleteTopicsResult DeleteTopics(TopicCollection topics)
Parameters
topics
TopicCollection
Returns
DeleteTopics(TopicCollection, DeleteTopicsOptions)
DeleteTopicsResult DeleteTopics(TopicCollection topics, DeleteTopicsOptions options)
Parameters
topics
TopicCollectionoptions
DeleteTopicsOptions
Returns
DescribeAcls(AclBindingFilter)
DescribeAclsResult DescribeAcls(AclBindingFilter filter)
Parameters
filter
AclBindingFilter
Returns
DescribeAcls(AclBindingFilter, DescribeAclsOptions)
DescribeAclsResult DescribeAcls(AclBindingFilter filter, DescribeAclsOptions options)
Parameters
filter
AclBindingFilteroptions
DescribeAclsOptions
Returns
DescribeClientQuotas(ClientQuotaFilter)
DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter)
Parameters
filter
ClientQuotaFilter
Returns
DescribeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)
DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter, DescribeClientQuotasOptions options)
Parameters
filter
ClientQuotaFilteroptions
DescribeClientQuotasOptions
Returns
DescribeCluster()
DescribeClusterResult DescribeCluster()
Returns
DescribeCluster(DescribeClusterOptions)
DescribeClusterResult DescribeCluster(DescribeClusterOptions options)
Parameters
options
DescribeClusterOptions
Returns
DescribeConfigs(Collection<ConfigResource>)
DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> resources)
Parameters
resources
Collection<ConfigResource>
Returns
DescribeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)
DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> resources, DescribeConfigsOptions options)
Parameters
resources
Collection<ConfigResource>options
DescribeConfigsOptions
Returns
DescribeConsumerGroups(Collection<String>)
DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> groupIds)
Parameters
groupIds
Collection<String>
Returns
DescribeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions)
DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> groupIds, DescribeConsumerGroupsOptions options)
Parameters
groupIds
Collection<String>options
DescribeConsumerGroupsOptions
Returns
DescribeDelegationToken()
DescribeDelegationTokenResult DescribeDelegationToken()
Returns
DescribeDelegationToken(DescribeDelegationTokenOptions)
DescribeDelegationTokenResult DescribeDelegationToken(DescribeDelegationTokenOptions options)
Parameters
options
DescribeDelegationTokenOptions
Returns
DescribeFeatures()
DescribeFeaturesResult DescribeFeatures()
Returns
DescribeFeatures(DescribeFeaturesOptions)
DescribeFeaturesResult DescribeFeatures(DescribeFeaturesOptions options)
Parameters
options
DescribeFeaturesOptions
Returns
DescribeLogDirs(Collection<Integer>)
DescribeLogDirsResult DescribeLogDirs(Collection<Integer> brokers)
Parameters
brokers
Collection<Integer>
Returns
DescribeLogDirs(Collection<Integer>, DescribeLogDirsOptions)
DescribeLogDirsResult DescribeLogDirs(Collection<Integer> brokers, DescribeLogDirsOptions options)
Parameters
brokers
Collection<Integer>options
DescribeLogDirsOptions
Returns
DescribeMetadataQuorum()
DescribeMetadataQuorumResult DescribeMetadataQuorum()
Returns
DescribeMetadataQuorum(DescribeMetadataQuorumOptions)
DescribeMetadataQuorumResult DescribeMetadataQuorum(DescribeMetadataQuorumOptions options)
Parameters
options
DescribeMetadataQuorumOptions
Returns
DescribeProducers(Collection<TopicPartition>)
DescribeProducersResult DescribeProducers(Collection<TopicPartition> partitions)
Parameters
partitions
Collection<TopicPartition>
Returns
DescribeProducers(Collection<TopicPartition>, DescribeProducersOptions)
DescribeProducersResult DescribeProducers(Collection<TopicPartition> partitions, DescribeProducersOptions options)
Parameters
partitions
Collection<TopicPartition>options
DescribeProducersOptions
Returns
DescribeReplicaLogDirs(Collection<TopicPartitionReplica>)
DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> replicas)
Parameters
replicas
Collection<TopicPartitionReplica>
Returns
DescribeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)
DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> replicas, DescribeReplicaLogDirsOptions options)
Parameters
replicas
Collection<TopicPartitionReplica>options
DescribeReplicaLogDirsOptions
Returns
DescribeTopics(Collection<String>)
DescribeTopicsResult DescribeTopics(Collection<String> topicNames)
Parameters
topicNames
Collection<String>
Returns
DescribeTopics(Collection<String>, DescribeTopicsOptions)
DescribeTopicsResult DescribeTopics(Collection<String> topicNames, DescribeTopicsOptions options)
Parameters
topicNames
Collection<String>options
DescribeTopicsOptions
Returns
DescribeTransactions(Collection<String>)
DescribeTransactionsResult DescribeTransactions(Collection<String> transactionalIds)
Parameters
transactionalIds
Collection<String>
Returns
DescribeTransactions(Collection<String>, DescribeTransactionsOptions)
DescribeTransactionsResult DescribeTransactions(Collection<String> transactionalIds, DescribeTransactionsOptions options)
Parameters
transactionalIds
Collection<String>options
DescribeTransactionsOptions
Returns
DescribeUserScramCredentials()
DescribeUserScramCredentialsResult DescribeUserScramCredentials()
Returns
DescribeUserScramCredentials(List<String>)
DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> users)
Parameters
Returns
DescribeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions)
DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> users, DescribeUserScramCredentialsOptions options)
Parameters
users
List<String>options
DescribeUserScramCredentialsOptions
Returns
ElectLeaders(ElectionType, Set<TopicPartition>)
ElectLeadersResult ElectLeaders(ElectionType electionType, Set<TopicPartition> partitions)
Parameters
electionType
ElectionTypepartitions
Set<TopicPartition>
Returns
ElectLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions)
ElectLeadersResult ElectLeaders(ElectionType electionType, Set<TopicPartition> partitions, ElectLeadersOptions options)
Parameters
electionType
ElectionTypepartitions
Set<TopicPartition>options
ElectLeadersOptions
Returns
ExpireDelegationToken(byte[])
ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac)
Parameters
hmac
byte[]
Returns
ExpireDelegationToken(byte[], ExpireDelegationTokenOptions)
ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac, ExpireDelegationTokenOptions options)
Parameters
hmac
byte[]options
ExpireDelegationTokenOptions
Returns
FenceProducers(Collection<String>)
FenceProducersResult FenceProducers(Collection<String> transactionalIds)
Parameters
transactionalIds
Collection<String>
Returns
FenceProducers(Collection<String>, FenceProducersOptions)
FenceProducersResult FenceProducers(Collection<String> transactionalIds, FenceProducersOptions options)
Parameters
transactionalIds
Collection<String>options
FenceProducersOptions
Returns
IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>)
AlterConfigsResult IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>> configs)
Parameters
configs
Map<ConfigResource, Collection<AlterConfigOp>>
Returns
IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions)
AlterConfigsResult IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>> configs, AlterConfigsOptions options)
Parameters
configs
Map<ConfigResource, Collection<AlterConfigOp>>options
AlterConfigsOptions
Returns
ListConsumerGroupOffsets(String)
ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId)
Parameters
groupId
String
Returns
ListConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)
ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)
Parameters
groupId
Stringoptions
ListConsumerGroupOffsetsOptions
Returns
ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>)
ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> groupSpecs)
Parameters
groupSpecs
Map<String, ListConsumerGroupOffsetsSpec>
Returns
ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions)
ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> groupSpecs, ListConsumerGroupOffsetsOptions options)
Parameters
groupSpecs
Map<String, ListConsumerGroupOffsetsSpec>options
ListConsumerGroupOffsetsOptions
Returns
ListConsumerGroups()
ListConsumerGroupsResult ListConsumerGroups()
Returns
ListConsumerGroups(ListConsumerGroupsOptions)
ListConsumerGroupsResult ListConsumerGroups(ListConsumerGroupsOptions options)
Parameters
options
ListConsumerGroupsOptions
Returns
ListOffsets(Map<TopicPartition, OffsetSpec>)
ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets)
Parameters
topicPartitionOffsets
Map<TopicPartition, OffsetSpec>
Returns
ListOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)
ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets, ListOffsetsOptions options)
Parameters
topicPartitionOffsets
Map<TopicPartition, OffsetSpec>options
ListOffsetsOptions
Returns
ListPartitionReassignments()
ListPartitionReassignmentsResult ListPartitionReassignments()
Returns
ListPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions)
ListPartitionReassignmentsResult ListPartitionReassignments(Optional<Set<TopicPartition>> partitions, ListPartitionReassignmentsOptions options)
Parameters
partitions
Optional<Set<TopicPartition>>options
ListPartitionReassignmentsOptions
Returns
ListPartitionReassignments(Set<TopicPartition>)
ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> partitions)
Parameters
partitions
Set<TopicPartition>
Returns
ListPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions)
ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> partitions, ListPartitionReassignmentsOptions options)
Parameters
partitions
Set<TopicPartition>options
ListPartitionReassignmentsOptions
Returns
ListPartitionReassignments(ListPartitionReassignmentsOptions)
ListPartitionReassignmentsResult ListPartitionReassignments(ListPartitionReassignmentsOptions options)
Parameters
Returns
ListTopics()
ListTopicsResult ListTopics()
Returns
ListTopics(ListTopicsOptions)
ListTopicsResult ListTopics(ListTopicsOptions options)
Parameters
options
ListTopicsOptions
Returns
ListTransactions()
ListTransactionsResult ListTransactions()
Returns
ListTransactions(ListTransactionsOptions)
ListTransactionsResult ListTransactions(ListTransactionsOptions options)
Parameters
options
ListTransactionsOptions
Returns
Metrics<T>()
Map<MetricName, T> Metrics<T>() where T : Metric
Returns
- Map<MetricName, T>
Type Parameters
T
RemoveMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)
RemoveMembersFromConsumerGroupResult RemoveMembersFromConsumerGroup(String groupId, RemoveMembersFromConsumerGroupOptions options)
Parameters
groupId
Stringoptions
RemoveMembersFromConsumerGroupOptions
Returns
RenewDelegationToken(byte[])
RenewDelegationTokenResult RenewDelegationToken(byte[] hmac)
Parameters
hmac
byte[]
Returns
RenewDelegationToken(byte[], RenewDelegationTokenOptions)
RenewDelegationTokenResult RenewDelegationToken(byte[] hmac, RenewDelegationTokenOptions options)
Parameters
hmac
byte[]options
RenewDelegationTokenOptions
Returns
UnregisterBroker(int)
UnregisterBrokerResult UnregisterBroker(int brokerId)
Parameters
brokerId
int
Returns
UnregisterBroker(int, UnregisterBrokerOptions)
UnregisterBrokerResult UnregisterBroker(int brokerId, UnregisterBrokerOptions options)
Parameters
brokerId
intoptions
UnregisterBrokerOptions
Returns
UpdateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions)
UpdateFeaturesResult UpdateFeatures(Map<String, FeatureUpdate> featureUpdates, UpdateFeaturesOptions options)
Parameters
featureUpdates
Map<String, FeatureUpdate>options
UpdateFeaturesOptions