Interface IAdmin

Namespace

Org.Apache.Kafka.Clients.Admin

Assembly

MASES.KNet.dll

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html

public interface IAdmin : IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, IAutoCloseable

Inherited Members

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

IDisposable.Dispose()

Extension Methods

KafkaAdminClientExtensions.AbortTransactionAsync(IAdmin, AbortTransactionSpec)

KafkaAdminClientExtensions.AbortTransactionAsync(IAdmin, AbortTransactionSpec, AbortTransactionOptions)

KafkaAdminClientExtensions.AlterClientQuotasAsync(IAdmin, Collection<ClientQuotaAlteration>)

KafkaAdminClientExtensions.AlterClientQuotasAsync(IAdmin, Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)

KafkaAdminClientExtensions.AlterConsumerGroupOffsetsAsync(IAdmin, string, Map<TopicPartition, OffsetAndMetadata>)

KafkaAdminClientExtensions.AlterConsumerGroupOffsetsAsync(IAdmin, string, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions)

KafkaAdminClientExtensions.AlterPartitionReassignmentsAsync(IAdmin, Map<TopicPartition, Optional<NewPartitionReassignment>>)

KafkaAdminClientExtensions.AlterPartitionReassignmentsAsync(IAdmin, Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions)

KafkaAdminClientExtensions.AlterReplicaLogDirsAsync(IAdmin, Map<TopicPartitionReplica, String>)

KafkaAdminClientExtensions.AlterReplicaLogDirsAsync(IAdmin, Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)

KafkaAdminClientExtensions.AlterUserScramCredentialsAsync(IAdmin, List<UserScramCredentialAlteration>)

KafkaAdminClientExtensions.AlterUserScramCredentialsAsync(IAdmin, List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)

KafkaAdminClientExtensions.CreateAclsAsync(IAdmin, Collection<AclBinding>)

KafkaAdminClientExtensions.CreateAclsAsync(IAdmin, Collection<AclBinding>, CreateAclsOptions)

KafkaAdminClientExtensions.CreateDelegationTokenAsync(IAdmin)

KafkaAdminClientExtensions.CreateDelegationTokenAsync(IAdmin, CreateDelegationTokenOptions)

KafkaAdminClientExtensions.CreatePartitionsAsync(IAdmin, Map<String, NewPartitions>)

KafkaAdminClientExtensions.CreatePartitionsAsync(IAdmin, Map<String, NewPartitions>, CreatePartitionsOptions)

KafkaAdminClientExtensions.CreateTopic(IAdmin, NewTopic)

KafkaAdminClientExtensions.CreateTopic(IAdmin, string, int, short)

KafkaAdminClientExtensions.CreateTopicAsync(IAdmin, string, int, short)

KafkaAdminClientExtensions.CreateTopicsAsync(IAdmin, Collection<NewTopic>)

KafkaAdminClientExtensions.CreateTopicsAsync(IAdmin, Collection<NewTopic>, CreateTopicsOptions)

KafkaAdminClientExtensions.DeleteAclsAsync(IAdmin, Collection<AclBindingFilter>)

KafkaAdminClientExtensions.DeleteAclsAsync(IAdmin, Collection<AclBindingFilter>, DeleteAclsOptions)

KafkaAdminClientExtensions.DeleteConsumerGroupOffsetsAsync(IAdmin, string, Set<TopicPartition>)

KafkaAdminClientExtensions.DeleteConsumerGroupOffsetsAsync(IAdmin, string, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)

KafkaAdminClientExtensions.DeleteConsumerGroupsAsync(IAdmin, IEnumerable<string>)

KafkaAdminClientExtensions.DeleteConsumerGroupsAsync(IAdmin, IEnumerable<string>, DeleteConsumerGroupsOptions)

KafkaAdminClientExtensions.DeleteRecordsAsync(IAdmin, Map<TopicPartition, RecordsToDelete>)

KafkaAdminClientExtensions.DeleteRecordsAsync(IAdmin, Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)

KafkaAdminClientExtensions.DeleteTopic(IAdmin, string)

KafkaAdminClientExtensions.DeleteTopicAsync(IAdmin, string)

KafkaAdminClientExtensions.DeleteTopicsAsync(IAdmin, TopicCollection)

KafkaAdminClientExtensions.DeleteTopicsAsync(IAdmin, TopicCollection, DeleteTopicsOptions)

KafkaAdminClientExtensions.DeleteTopicsAsync(IAdmin, IEnumerable<string>)

KafkaAdminClientExtensions.DeleteTopicsAsync(IAdmin, IEnumerable<string>, DeleteTopicsOptions)

KafkaAdminClientExtensions.DescribeAclsAsync(IAdmin, AclBindingFilter)

KafkaAdminClientExtensions.DescribeAclsAsync(IAdmin, AclBindingFilter, DescribeAclsOptions)

KafkaAdminClientExtensions.DescribeClientQuotasAsync(IAdmin, ClientQuotaFilter)

KafkaAdminClientExtensions.DescribeClientQuotasAsync(IAdmin, ClientQuotaFilter, DescribeClientQuotasOptions)

KafkaAdminClientExtensions.DescribeClusterAsync(IAdmin)

KafkaAdminClientExtensions.DescribeClusterAsync(IAdmin, DescribeClusterOptions)

KafkaAdminClientExtensions.DescribeConfigsAsync(IAdmin, Collection<ConfigResource>)

KafkaAdminClientExtensions.DescribeConfigsAsync(IAdmin, Collection<ConfigResource>, DescribeConfigsOptions)

KafkaAdminClientExtensions.DescribeConsumerGroupsAsync(IAdmin, IEnumerable<string>)

KafkaAdminClientExtensions.DescribeConsumerGroupsAsync(IAdmin, IEnumerable<string>, DescribeConsumerGroupsOptions)

KafkaAdminClientExtensions.DescribeDelegationTokenAsync(IAdmin)

KafkaAdminClientExtensions.DescribeDelegationTokenAsync(IAdmin, DescribeDelegationTokenOptions)

KafkaAdminClientExtensions.DescribeFeaturesAsync(IAdmin)

KafkaAdminClientExtensions.DescribeFeaturesAsync(IAdmin, DescribeFeaturesOptions)

KafkaAdminClientExtensions.DescribeLogDirsAsync(IAdmin, Collection<Integer>)

KafkaAdminClientExtensions.DescribeLogDirsAsync(IAdmin, Collection<Integer>, DescribeLogDirsOptions)

KafkaAdminClientExtensions.DescribeProducersAsync(IAdmin, Collection<TopicPartition>)

KafkaAdminClientExtensions.DescribeProducersAsync(IAdmin, Collection<TopicPartition>, DescribeProducersOptions)

KafkaAdminClientExtensions.DescribeReplicaLogDirsAsync(IAdmin, Collection<TopicPartitionReplica>)

KafkaAdminClientExtensions.DescribeReplicaLogDirsAsync(IAdmin, Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)

KafkaAdminClientExtensions.DescribeTopicAsync(IAdmin, string)

KafkaAdminClientExtensions.DescribeTopicsAsync(IAdmin, IEnumerable<string>)

KafkaAdminClientExtensions.DescribeTopicsAsync(IAdmin, IEnumerable<string>, DescribeTopicsOptions)

KafkaAdminClientExtensions.DescribeTransactionsAsync(IAdmin, IEnumerable<string>)

KafkaAdminClientExtensions.DescribeTransactionsAsync(IAdmin, IEnumerable<string>, DescribeTransactionsOptions)

KafkaAdminClientExtensions.DescribeUserScramCredentialsAsync(IAdmin)

KafkaAdminClientExtensions.DescribeUserScramCredentialsAsync(IAdmin, List<String>)

KafkaAdminClientExtensions.DescribeUserScramCredentialsAsync(IAdmin, List<String>, DescribeUserScramCredentialsOptions)

KafkaAdminClientExtensions.ElectLeadersAsync(IAdmin, ElectionType, Set<TopicPartition>)

KafkaAdminClientExtensions.ElectLeadersAsync(IAdmin, ElectionType, Set<TopicPartition>, ElectLeadersOptions)

KafkaAdminClientExtensions.ExpireDelegationTokenAsync(IAdmin, byte[])

KafkaAdminClientExtensions.ExpireDelegationTokenAsync(IAdmin, byte[], ExpireDelegationTokenOptions)

KafkaAdminClientExtensions.IncrementalAlterConfigsAsync(IAdmin, Map<ConfigResource, Collection<AlterConfigOp>>)

KafkaAdminClientExtensions.IncrementalAlterConfigsAsync(IAdmin, Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions)

KafkaAdminClientExtensions.ListConsumerGroupOffsetsAsync(IAdmin, string)

KafkaAdminClientExtensions.ListConsumerGroupOffsetsAsync(IAdmin, string, ListConsumerGroupOffsetsOptions)

KafkaAdminClientExtensions.ListOffsetsAsync(IAdmin, Map<TopicPartition, OffsetSpec>)

KafkaAdminClientExtensions.ListOffsetsAsync(IAdmin, Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)

KafkaAdminClientExtensions.ListPartitionReassignmentsAsync(IAdmin)

KafkaAdminClientExtensions.ListPartitionReassignmentsAsync(IAdmin, Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions)

KafkaAdminClientExtensions.ListPartitionReassignmentsAsync(IAdmin, Set<TopicPartition>)

KafkaAdminClientExtensions.ListPartitionReassignmentsAsync(IAdmin, Set<TopicPartition>, ListPartitionReassignmentsOptions)

KafkaAdminClientExtensions.ListPartitionReassignmentsAsync(IAdmin, ListPartitionReassignmentsOptions)

KafkaAdminClientExtensions.ListTopicsAsync(IAdmin)

KafkaAdminClientExtensions.ListTopicsAsync(IAdmin, ListTopicsOptions)

KafkaAdminClientExtensions.ListTransactionsAsync(IAdmin)

KafkaAdminClientExtensions.ListTransactionsAsync(IAdmin, ListTransactionsOptions)

KafkaAdminClientExtensions.RemoveMembersFromConsumerGroupAsync(IAdmin, string, RemoveMembersFromConsumerGroupOptions)

KafkaAdminClientExtensions.RenewDelegationTokenAsync(IAdmin, byte[])

KafkaAdminClientExtensions.RenewDelegationTokenAsync(IAdmin, byte[], RenewDelegationTokenOptions)

KafkaAdminClientExtensions.UnregisterBrokerAsync(IAdmin, int)

KafkaAdminClientExtensions.UnregisterBrokerAsync(IAdmin, int, UnregisterBrokerOptions)

KafkaAdminClientExtensions.UpdateFeaturesAsync(IAdmin, Map<String, FeatureUpdate>, UpdateFeaturesOptions)

Methods

AbortTransaction(AbortTransactionSpec)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#abortTransaction(org.apache.kafka.clients.admin.AbortTransactionSpec)

AbortTransactionResult AbortTransaction(AbortTransactionSpec spec)

Parameters

spec AbortTransactionSpec

Returns

AbortTransactionResult

AbortTransactionResult

AbortTransaction(AbortTransactionSpec, AbortTransactionOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#abortTransaction(org.apache.kafka.clients.admin.AbortTransactionSpec,org.apache.kafka.clients.admin.AbortTransactionOptions)

AbortTransactionResult AbortTransaction(AbortTransactionSpec spec, AbortTransactionOptions options)

Parameters

spec AbortTransactionSpec

options AbortTransactionOptions

Returns

AbortTransactionResult

AbortTransactionResult

AlterClientQuotas(Collection<ClientQuotaAlteration>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterClientQuotas(java.util.Collection)

AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> entries)

Parameters

entries Collection<ClientQuotaAlteration>

Returns

AlterClientQuotasResult

AlterClientQuotasResult

AlterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterClientQuotas(java.util.Collection,org.apache.kafka.clients.admin.AlterClientQuotasOptions)

AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> entries, AlterClientQuotasOptions options)

Parameters

entries Collection<ClientQuotaAlteration>

options AlterClientQuotasOptions

Returns

AlterClientQuotasResult

AlterClientQuotasResult

AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterConsumerGroupOffsets(java.lang.String,java.util.Map)

AlterConsumerGroupOffsetsResult AlterConsumerGroupOffsets(String groupId, Map<TopicPartition, OffsetAndMetadata> offsets)

Parameters

groupId String

offsets Map<TopicPartition, OffsetAndMetadata>

Returns

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterConsumerGroupOffsets(java.lang.String,java.util.Map,org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions)

AlterConsumerGroupOffsetsResult AlterConsumerGroupOffsets(String groupId, Map<TopicPartition, OffsetAndMetadata> offsets, AlterConsumerGroupOffsetsOptions options)

Parameters

groupId String

offsets Map<TopicPartition, OffsetAndMetadata>

options AlterConsumerGroupOffsetsOptions

Returns

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsetsResult

AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterPartitionReassignments(java.util.Map)

AlterPartitionReassignmentsResult AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>> reassignments)

Parameters

reassignments Map<TopicPartition, Optional<NewPartitionReassignment>>

Returns

AlterPartitionReassignmentsResult

AlterPartitionReassignmentsResult

AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterPartitionReassignments(java.util.Map,org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions)

AlterPartitionReassignmentsResult AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>> reassignments, AlterPartitionReassignmentsOptions options)

Parameters

reassignments Map<TopicPartition, Optional<NewPartitionReassignment>>

options AlterPartitionReassignmentsOptions

Returns

AlterPartitionReassignmentsResult

AlterPartitionReassignmentsResult

AlterReplicaLogDirs(Map<TopicPartitionReplica, String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterReplicaLogDirs(java.util.Map)

AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> replicaAssignment)

Parameters

replicaAssignment Map<TopicPartitionReplica, String>

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterReplicaLogDirs(java.util.Map,org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions)

AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> replicaAssignment, AlterReplicaLogDirsOptions options)

Parameters

replicaAssignment Map<TopicPartitionReplica, String>

options AlterReplicaLogDirsOptions

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterUserScramCredentials(java.util.List)

AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> alterations)

Parameters

alterations List<UserScramCredentialAlteration>

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#alterUserScramCredentials(java.util.List,org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions)

AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> alterations, AlterUserScramCredentialsOptions options)

Parameters

alterations List<UserScramCredentialAlteration>

options AlterUserScramCredentialsOptions

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#close()

void Close()

Close(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#close(java.time.Duration)

void Close(Duration timeout)

Parameters

timeout Duration

CreateAcls(Collection<AclBinding>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createAcls(java.util.Collection)

CreateAclsResult CreateAcls(Collection<AclBinding> acls)

Parameters

acls Collection<AclBinding>

Returns

CreateAclsResult

CreateAclsResult

CreateAcls(Collection<AclBinding>, CreateAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createAcls(java.util.Collection,org.apache.kafka.clients.admin.CreateAclsOptions)

CreateAclsResult CreateAcls(Collection<AclBinding> acls, CreateAclsOptions options)

Parameters

acls Collection<AclBinding>

options CreateAclsOptions

Returns

CreateAclsResult

CreateAclsResult

CreateDelegationToken()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createDelegationToken()

CreateDelegationTokenResult CreateDelegationToken()

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreateDelegationToken(CreateDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createDelegationToken(org.apache.kafka.clients.admin.CreateDelegationTokenOptions)

CreateDelegationTokenResult CreateDelegationToken(CreateDelegationTokenOptions options)

Parameters

options CreateDelegationTokenOptions

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreatePartitions(Map<String, NewPartitions>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createPartitions(java.util.Map)

CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> newPartitions)

Parameters

newPartitions Map<String, NewPartitions>

Returns

CreatePartitionsResult

CreatePartitionsResult

CreatePartitions(Map<String, NewPartitions>, CreatePartitionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createPartitions(java.util.Map,org.apache.kafka.clients.admin.CreatePartitionsOptions)

CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> newPartitions, CreatePartitionsOptions options)

Parameters

newPartitions Map<String, NewPartitions>

options CreatePartitionsOptions

Returns

CreatePartitionsResult

CreatePartitionsResult

CreateTopics(Collection<NewTopic>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createTopics(java.util.Collection)

CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics)

Parameters

newTopics Collection<NewTopic>

Returns

CreateTopicsResult

CreateTopicsResult

CreateTopics(Collection<NewTopic>, CreateTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#createTopics(java.util.Collection,org.apache.kafka.clients.admin.CreateTopicsOptions)

CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics, CreateTopicsOptions options)

Parameters

newTopics Collection<NewTopic>

options CreateTopicsOptions

Returns

CreateTopicsResult

CreateTopicsResult

DeleteAcls(Collection<AclBindingFilter>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteAcls(java.util.Collection)

DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> filters)

Parameters

filters Collection<AclBindingFilter>

Returns

DeleteAclsResult

DeleteAclsResult

DeleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteAcls(java.util.Collection,org.apache.kafka.clients.admin.DeleteAclsOptions)

DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> filters, DeleteAclsOptions options)

Parameters

filters Collection<AclBindingFilter>

options DeleteAclsOptions

Returns

DeleteAclsResult

DeleteAclsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteConsumerGroupOffsets(java.lang.String,java.util.Set)

DeleteConsumerGroupOffsetsResult DeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)

Parameters

groupId String

partitions Set<TopicPartition>

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteConsumerGroupOffsets(java.lang.String,java.util.Set,org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions)

DeleteConsumerGroupOffsetsResult DeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, DeleteConsumerGroupOffsetsOptions options)

Parameters

groupId String

partitions Set<TopicPartition>

options DeleteConsumerGroupOffsetsOptions

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroups(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteConsumerGroups(java.util.Collection)

DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> groupIds)

Parameters

groupIds Collection<String>

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteConsumerGroups(java.util.Collection,org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions)

DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> groupIds, DeleteConsumerGroupsOptions options)

Parameters

groupIds Collection<String>

options DeleteConsumerGroupsOptions

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteRecords(java.util.Map)

DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete)

Parameters

recordsToDelete Map<TopicPartition, RecordsToDelete>

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteRecords(java.util.Map,org.apache.kafka.clients.admin.DeleteRecordsOptions)

DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete, DeleteRecordsOptions options)

Parameters

recordsToDelete Map<TopicPartition, RecordsToDelete>

options DeleteRecordsOptions

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteTopics(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteTopics(java.util.Collection)

DeleteTopicsResult DeleteTopics(Collection<String> topics)

Parameters

topics Collection<String>

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(Collection<String>, DeleteTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteTopics(java.util.Collection,org.apache.kafka.clients.admin.DeleteTopicsOptions)

DeleteTopicsResult DeleteTopics(Collection<String> topics, DeleteTopicsOptions options)

Parameters

topics Collection<String>

options DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteTopics(org.apache.kafka.common.TopicCollection)

DeleteTopicsResult DeleteTopics(TopicCollection topics)

Parameters

topics TopicCollection

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection, DeleteTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#deleteTopics(org.apache.kafka.common.TopicCollection,org.apache.kafka.clients.admin.DeleteTopicsOptions)

DeleteTopicsResult DeleteTopics(TopicCollection topics, DeleteTopicsOptions options)

Parameters

topics TopicCollection

options DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DescribeAcls(AclBindingFilter)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeAcls(org.apache.kafka.common.acl.AclBindingFilter)

DescribeAclsResult DescribeAcls(AclBindingFilter filter)

Parameters

filter AclBindingFilter

Returns

DescribeAclsResult

DescribeAclsResult

DescribeAcls(AclBindingFilter, DescribeAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeAcls(org.apache.kafka.common.acl.AclBindingFilter,org.apache.kafka.clients.admin.DescribeAclsOptions)

DescribeAclsResult DescribeAcls(AclBindingFilter filter, DescribeAclsOptions options)

Parameters

filter AclBindingFilter

options DescribeAclsOptions

Returns

DescribeAclsResult

DescribeAclsResult

DescribeClientQuotas(ClientQuotaFilter)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeClientQuotas(org.apache.kafka.common.quota.ClientQuotaFilter)

DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter)

Parameters

filter ClientQuotaFilter

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeClientQuotas(org.apache.kafka.common.quota.ClientQuotaFilter,org.apache.kafka.clients.admin.DescribeClientQuotasOptions)

DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter, DescribeClientQuotasOptions options)

Parameters

filter ClientQuotaFilter

options DescribeClientQuotasOptions

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeCluster()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeCluster()

DescribeClusterResult DescribeCluster()

Returns

DescribeClusterResult

DescribeClusterResult

DescribeCluster(DescribeClusterOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeCluster(org.apache.kafka.clients.admin.DescribeClusterOptions)

DescribeClusterResult DescribeCluster(DescribeClusterOptions options)

Parameters

options DescribeClusterOptions

Returns

DescribeClusterResult

DescribeClusterResult

DescribeConfigs(Collection<ConfigResource>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeConfigs(java.util.Collection)

DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> resources)

Parameters

resources Collection<ConfigResource>

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeConfigs(java.util.Collection,org.apache.kafka.clients.admin.DescribeConfigsOptions)

DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> resources, DescribeConfigsOptions options)

Parameters

resources Collection<ConfigResource>

options DescribeConfigsOptions

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConsumerGroups(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeConsumerGroups(java.util.Collection)

DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> groupIds)

Parameters

groupIds Collection<String>

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeConsumerGroups(java.util.Collection,org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions)

DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> groupIds, DescribeConsumerGroupsOptions options)

Parameters

groupIds Collection<String>

options DescribeConsumerGroupsOptions

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeDelegationToken()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeDelegationToken()

DescribeDelegationTokenResult DescribeDelegationToken()

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeDelegationToken(DescribeDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeDelegationToken(org.apache.kafka.clients.admin.DescribeDelegationTokenOptions)

DescribeDelegationTokenResult DescribeDelegationToken(DescribeDelegationTokenOptions options)

Parameters

options DescribeDelegationTokenOptions

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeFeatures()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeFeatures()

DescribeFeaturesResult DescribeFeatures()

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeFeatures(DescribeFeaturesOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeFeatures(org.apache.kafka.clients.admin.DescribeFeaturesOptions)

DescribeFeaturesResult DescribeFeatures(DescribeFeaturesOptions options)

Parameters

options DescribeFeaturesOptions

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeLogDirs(Collection<Integer>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeLogDirs(java.util.Collection)

DescribeLogDirsResult DescribeLogDirs(Collection<Integer> brokers)

Parameters

brokers Collection<Integer>

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeLogDirs(Collection<Integer>, DescribeLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeLogDirs(java.util.Collection,org.apache.kafka.clients.admin.DescribeLogDirsOptions)

DescribeLogDirsResult DescribeLogDirs(Collection<Integer> brokers, DescribeLogDirsOptions options)

Parameters

brokers Collection<Integer>

options DescribeLogDirsOptions

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeMetadataQuorum()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeMetadataQuorum()

DescribeMetadataQuorumResult DescribeMetadataQuorum()

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeMetadataQuorum(DescribeMetadataQuorumOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeMetadataQuorum(org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions)

DescribeMetadataQuorumResult DescribeMetadataQuorum(DescribeMetadataQuorumOptions options)

Parameters

options DescribeMetadataQuorumOptions

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeProducers(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeProducers(java.util.Collection)

DescribeProducersResult DescribeProducers(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Returns

DescribeProducersResult

DescribeProducersResult

DescribeProducers(Collection<TopicPartition>, DescribeProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeProducers(java.util.Collection,org.apache.kafka.clients.admin.DescribeProducersOptions)

DescribeProducersResult DescribeProducers(Collection<TopicPartition> partitions, DescribeProducersOptions options)

Parameters

partitions Collection<TopicPartition>

options DescribeProducersOptions

Returns

DescribeProducersResult

DescribeProducersResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeReplicaLogDirs(java.util.Collection)

DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> replicas)

Parameters

replicas Collection<TopicPartitionReplica>

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeReplicaLogDirs(java.util.Collection,org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions)

DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> replicas, DescribeReplicaLogDirsOptions options)

Parameters

replicas Collection<TopicPartitionReplica>

options DescribeReplicaLogDirsOptions

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeTopics(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeTopics(java.util.Collection)

DescribeTopicsResult DescribeTopics(Collection<String> topicNames)

Parameters

topicNames Collection<String>

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTopics(Collection<String>, DescribeTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeTopics(java.util.Collection,org.apache.kafka.clients.admin.DescribeTopicsOptions)

DescribeTopicsResult DescribeTopics(Collection<String> topicNames, DescribeTopicsOptions options)

Parameters

topicNames Collection<String>

options DescribeTopicsOptions

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTransactions(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeTransactions(java.util.Collection)

DescribeTransactionsResult DescribeTransactions(Collection<String> transactionalIds)

Parameters

transactionalIds Collection<String>

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeTransactions(Collection<String>, DescribeTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeTransactions(java.util.Collection,org.apache.kafka.clients.admin.DescribeTransactionsOptions)

DescribeTransactionsResult DescribeTransactions(Collection<String> transactionalIds, DescribeTransactionsOptions options)

Parameters

transactionalIds Collection<String>

options DescribeTransactionsOptions

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeUserScramCredentials()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeUserScramCredentials()

DescribeUserScramCredentialsResult DescribeUserScramCredentials()

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeUserScramCredentials(java.util.List)

DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> users)

Parameters

users List<String>

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#describeUserScramCredentials(java.util.List,org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions)

DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> users, DescribeUserScramCredentialsOptions options)

Parameters

users List<String>

options DescribeUserScramCredentialsOptions

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

ElectLeaders(ElectionType, Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#electLeaders(org.apache.kafka.common.ElectionType,java.util.Set)

ElectLeadersResult ElectLeaders(ElectionType electionType, Set<TopicPartition> partitions)

Parameters

electionType ElectionType

partitions Set<TopicPartition>

Returns

ElectLeadersResult

ElectLeadersResult

ElectLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#electLeaders(org.apache.kafka.common.ElectionType,java.util.Set,org.apache.kafka.clients.admin.ElectLeadersOptions)

ElectLeadersResult ElectLeaders(ElectionType electionType, Set<TopicPartition> partitions, ElectLeadersOptions options)

Parameters

electionType ElectionType

partitions Set<TopicPartition>

options ElectLeadersOptions

Returns

ElectLeadersResult

ElectLeadersResult

ExpireDelegationToken(byte[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#expireDelegationToken(byte[])

ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac)

Parameters

hmac byte[]

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

ExpireDelegationToken(byte[], ExpireDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#expireDelegationToken(byte[],org.apache.kafka.clients.admin.ExpireDelegationTokenOptions)

ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac, ExpireDelegationTokenOptions options)

Parameters

hmac byte[]

options ExpireDelegationTokenOptions

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

FenceProducers(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#fenceProducers(java.util.Collection)

FenceProducersResult FenceProducers(Collection<String> transactionalIds)

Parameters

transactionalIds Collection<String>

Returns

FenceProducersResult

FenceProducersResult

FenceProducers(Collection<String>, FenceProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#fenceProducers(java.util.Collection,org.apache.kafka.clients.admin.FenceProducersOptions)

FenceProducersResult FenceProducers(Collection<String> transactionalIds, FenceProducersOptions options)

Parameters

transactionalIds Collection<String>

options FenceProducersOptions

Returns

FenceProducersResult

FenceProducersResult

IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#incrementalAlterConfigs(java.util.Map)

AlterConfigsResult IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>> configs)

Parameters

configs Map<ConfigResource, Collection<AlterConfigOp>>

Returns

AlterConfigsResult

AlterConfigsResult

IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#incrementalAlterConfigs(java.util.Map,org.apache.kafka.clients.admin.AlterConfigsOptions)

AlterConfigsResult IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>> configs, AlterConfigsOptions options)

Parameters

configs Map<ConfigResource, Collection<AlterConfigOp>>

options AlterConfigsOptions

Returns

AlterConfigsResult

AlterConfigsResult

ListConsumerGroupOffsets(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listConsumerGroupOffsets(java.lang.String)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId)

Parameters

groupId String

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listConsumerGroupOffsets(java.lang.String,org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)

Parameters

groupId String

options ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listConsumerGroupOffsets(java.util.Map)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> groupSpecs)

Parameters

groupSpecs Map<String, ListConsumerGroupOffsetsSpec>

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listConsumerGroupOffsets(java.util.Map,org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> groupSpecs, ListConsumerGroupOffsetsOptions options)

Parameters

groupSpecs Map<String, ListConsumerGroupOffsetsSpec>

options ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListOffsets(Map<TopicPartition, OffsetSpec>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listOffsets(java.util.Map)

ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets)

Parameters

topicPartitionOffsets Map<TopicPartition, OffsetSpec>

Returns

ListOffsetsResult

ListOffsetsResult

ListOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listOffsets(java.util.Map,org.apache.kafka.clients.admin.ListOffsetsOptions)

ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets, ListOffsetsOptions options)

Parameters

topicPartitionOffsets Map<TopicPartition, OffsetSpec>

options ListOffsetsOptions

Returns

ListOffsetsResult

ListOffsetsResult

ListPartitionReassignments()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listPartitionReassignments()

ListPartitionReassignmentsResult ListPartitionReassignments()

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listPartitionReassignments(java.util.Optional,org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions)

ListPartitionReassignmentsResult ListPartitionReassignments(Optional<Set<TopicPartition>> partitions, ListPartitionReassignmentsOptions options)

Parameters

partitions Optional<Set<TopicPartition>>

options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listPartitionReassignments(java.util.Set)

ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> partitions)

Parameters

partitions Set<TopicPartition>

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listPartitionReassignments(java.util.Set,org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions)

ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> partitions, ListPartitionReassignmentsOptions options)

Parameters

partitions Set<TopicPartition>

options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(ListPartitionReassignmentsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listPartitionReassignments(org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions)

ListPartitionReassignmentsResult ListPartitionReassignments(ListPartitionReassignmentsOptions options)

Parameters

options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listTopics()

ListTopicsResult ListTopics()

Returns

ListTopicsResult

ListTopicsResult

ListTopics(ListTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listTopics(org.apache.kafka.clients.admin.ListTopicsOptions)

ListTopicsResult ListTopics(ListTopicsOptions options)

Parameters

options ListTopicsOptions

Returns

ListTopicsResult

ListTopicsResult

ListTransactions()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listTransactions()

ListTransactionsResult ListTransactions()

Returns

ListTransactionsResult

ListTransactionsResult

ListTransactions(ListTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#listTransactions(org.apache.kafka.clients.admin.ListTransactionsOptions)

ListTransactionsResult ListTransactions(ListTransactionsOptions options)

Parameters

options ListTransactionsOptions

Returns

ListTransactionsResult

ListTransactionsResult

Metrics<T>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#metrics()

Map<MetricName, T> Metrics<T>() where T : Metric

Returns

Map<MetricName, T>

Map

Type Parameters

T

RemoveMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#removeMembersFromConsumerGroup(java.lang.String,org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions)

RemoveMembersFromConsumerGroupResult RemoveMembersFromConsumerGroup(String groupId, RemoveMembersFromConsumerGroupOptions options)

Parameters

groupId String

options RemoveMembersFromConsumerGroupOptions

Returns

RemoveMembersFromConsumerGroupResult

RemoveMembersFromConsumerGroupResult

RenewDelegationToken(byte[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#renewDelegationToken(byte[])

RenewDelegationTokenResult RenewDelegationToken(byte[] hmac)

Parameters

hmac byte[]

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

RenewDelegationToken(byte[], RenewDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#renewDelegationToken(byte[],org.apache.kafka.clients.admin.RenewDelegationTokenOptions)

RenewDelegationTokenResult RenewDelegationToken(byte[] hmac, RenewDelegationTokenOptions options)

Parameters

hmac byte[]

options RenewDelegationTokenOptions

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

UnregisterBroker(int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#unregisterBroker(int)

UnregisterBrokerResult UnregisterBroker(int brokerId)

Parameters

brokerId int

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UnregisterBroker(int, UnregisterBrokerOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#unregisterBroker(int,org.apache.kafka.clients.admin.UnregisterBrokerOptions)

UnregisterBrokerResult UnregisterBroker(int brokerId, UnregisterBrokerOptions options)

Parameters

brokerId int

options UnregisterBrokerOptions

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UpdateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/admin/Admin.html#updateFeatures(java.util.Map,org.apache.kafka.clients.admin.UpdateFeaturesOptions)

UpdateFeaturesResult UpdateFeatures(Map<String, FeatureUpdate> featureUpdates, UpdateFeaturesOptions options)

Parameters

featureUpdates Map<String, FeatureUpdate>

options UpdateFeaturesOptions

Returns

UpdateFeaturesResult

UpdateFeaturesResult