Table of Contents

Interface IAdmin

Namespace
Org.Apache.Kafka.Clients.Admin
Assembly
MASES.KNet.dll

.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.DynBridgeInstance
IJVMBridgeBase.BridgeInstance
IJVMBridgeDefinition.BridgeClassName
IJVMBridgeDefinition.IsBridgeInterface
IJVMBridgeDefinition.IsBridgeAbstract
IJVMBridgeDefinition.IsBridgeStatic
IJVMBridgeDefinition.IsBridgeCloseable
IJVMBridgeDefinition.IsBridgeListener
Extension Methods

Methods

AbortTransaction(AbortTransactionSpec)

AbortTransactionResult AbortTransaction(AbortTransactionSpec spec)

Parameters

spec AbortTransactionSpec

Returns

AbortTransactionResult

AbortTransactionResult

AbortTransaction(AbortTransactionSpec, AbortTransactionOptions)

AbortTransactionResult AbortTransaction(AbortTransactionSpec spec, AbortTransactionOptions options)

Parameters

spec AbortTransactionSpec
options AbortTransactionOptions

Returns

AbortTransactionResult

AbortTransactionResult

AlterClientQuotas(Collection<ClientQuotaAlteration>)

AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> entries)

Parameters

entries Collection<ClientQuotaAlteration>

Returns

AlterClientQuotasResult

AlterClientQuotasResult

AlterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)

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

Parameters

entries Collection<ClientQuotaAlteration>
options AlterClientQuotasOptions

Returns

AlterClientQuotasResult

AlterClientQuotasResult

AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>)

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

Parameters

groupId String
offsets Map<TopicPartition, OffsetAndMetadata>

Returns

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, 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>>)

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

Parameters

reassignments Map<TopicPartition, Optional<NewPartitionReassignment>>

Returns

AlterPartitionReassignmentsResult

AlterPartitionReassignmentsResult

AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, 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>)

AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> replicaAssignment)

Parameters

replicaAssignment Map<TopicPartitionReplica, String>

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)

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

Parameters

replicaAssignment Map<TopicPartitionReplica, String>
options AlterReplicaLogDirsOptions

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>)

AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> alterations)

Parameters

alterations List<UserScramCredentialAlteration>

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)

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

Parameters

alterations List<UserScramCredentialAlteration>
options AlterUserScramCredentialsOptions

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

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

CreateAclsResult

CreateAclsResult

CreateAcls(Collection<AclBinding>, CreateAclsOptions)

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

Parameters

acls Collection<AclBinding>
options CreateAclsOptions

Returns

CreateAclsResult

CreateAclsResult

CreateDelegationToken()

CreateDelegationTokenResult CreateDelegationToken()

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreateDelegationToken(CreateDelegationTokenOptions)

CreateDelegationTokenResult CreateDelegationToken(CreateDelegationTokenOptions options)

Parameters

options CreateDelegationTokenOptions

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreatePartitions(Map<String, NewPartitions>)

CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> newPartitions)

Parameters

newPartitions Map<String, NewPartitions>

Returns

CreatePartitionsResult

CreatePartitionsResult

CreatePartitions(Map<String, NewPartitions>, CreatePartitionsOptions)

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

Parameters

newPartitions Map<String, NewPartitions>
options CreatePartitionsOptions

Returns

CreatePartitionsResult

CreatePartitionsResult

CreateTopics(Collection<NewTopic>)

CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics)

Parameters

newTopics Collection<NewTopic>

Returns

CreateTopicsResult

CreateTopicsResult

CreateTopics(Collection<NewTopic>, CreateTopicsOptions)

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

Parameters

newTopics Collection<NewTopic>
options CreateTopicsOptions

Returns

CreateTopicsResult

CreateTopicsResult

DeleteAcls(Collection<AclBindingFilter>)

DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> filters)

Parameters

filters Collection<AclBindingFilter>

Returns

DeleteAclsResult

DeleteAclsResult

DeleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)

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

Parameters

filters Collection<AclBindingFilter>
options DeleteAclsOptions

Returns

DeleteAclsResult

DeleteAclsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>)

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

Parameters

groupId String
partitions Set<TopicPartition>

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)

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

Parameters

groupId String
partitions Set<TopicPartition>
options DeleteConsumerGroupOffsetsOptions

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroups(Collection<String>)

DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> groupIds)

Parameters

groupIds Collection<String>

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions)

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

Parameters

groupIds Collection<String>
options DeleteConsumerGroupsOptions

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>)

DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete)

Parameters

recordsToDelete Map<TopicPartition, RecordsToDelete>

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)

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

Parameters

recordsToDelete Map<TopicPartition, RecordsToDelete>
options DeleteRecordsOptions

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteTopics(Collection<String>)

DeleteTopicsResult DeleteTopics(Collection<String> topics)

Parameters

topics Collection<String>

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(Collection<String>, DeleteTopicsOptions)

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

Parameters

topics Collection<String>
options DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection)

DeleteTopicsResult DeleteTopics(TopicCollection topics)

Parameters

topics TopicCollection

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection, DeleteTopicsOptions)

DeleteTopicsResult DeleteTopics(TopicCollection topics, DeleteTopicsOptions options)

Parameters

topics TopicCollection
options DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DescribeAcls(AclBindingFilter)

DescribeAclsResult DescribeAcls(AclBindingFilter filter)

Parameters

filter AclBindingFilter

Returns

DescribeAclsResult

DescribeAclsResult

DescribeAcls(AclBindingFilter, DescribeAclsOptions)

DescribeAclsResult DescribeAcls(AclBindingFilter filter, DescribeAclsOptions options)

Parameters

filter AclBindingFilter
options DescribeAclsOptions

Returns

DescribeAclsResult

DescribeAclsResult

DescribeClientQuotas(ClientQuotaFilter)

DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter)

Parameters

filter ClientQuotaFilter

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)

DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter filter, DescribeClientQuotasOptions options)

Parameters

filter ClientQuotaFilter
options DescribeClientQuotasOptions

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeCluster()

DescribeClusterResult DescribeCluster()

Returns

DescribeClusterResult

DescribeClusterResult

DescribeCluster(DescribeClusterOptions)

DescribeClusterResult DescribeCluster(DescribeClusterOptions options)

Parameters

options DescribeClusterOptions

Returns

DescribeClusterResult

DescribeClusterResult

DescribeConfigs(Collection<ConfigResource>)

DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> resources)

Parameters

resources Collection<ConfigResource>

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)

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

Parameters

resources Collection<ConfigResource>
options DescribeConfigsOptions

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConsumerGroups(Collection<String>)

DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> groupIds)

Parameters

groupIds Collection<String>

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions)

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

Parameters

groupIds Collection<String>
options DescribeConsumerGroupsOptions

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeDelegationToken()

DescribeDelegationTokenResult DescribeDelegationToken()

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeDelegationToken(DescribeDelegationTokenOptions)

DescribeDelegationTokenResult DescribeDelegationToken(DescribeDelegationTokenOptions options)

Parameters

options DescribeDelegationTokenOptions

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeFeatures()

DescribeFeaturesResult DescribeFeatures()

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeFeatures(DescribeFeaturesOptions)

DescribeFeaturesResult DescribeFeatures(DescribeFeaturesOptions options)

Parameters

options DescribeFeaturesOptions

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeLogDirs(Collection<Integer>)

DescribeLogDirsResult DescribeLogDirs(Collection<Integer> brokers)

Parameters

brokers Collection<Integer>

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeLogDirs(Collection<Integer>, DescribeLogDirsOptions)

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

Parameters

brokers Collection<Integer>
options DescribeLogDirsOptions

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeMetadataQuorum()

DescribeMetadataQuorumResult DescribeMetadataQuorum()

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeMetadataQuorum(DescribeMetadataQuorumOptions)

DescribeMetadataQuorumResult DescribeMetadataQuorum(DescribeMetadataQuorumOptions options)

Parameters

options DescribeMetadataQuorumOptions

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeProducers(Collection<TopicPartition>)

DescribeProducersResult DescribeProducers(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Returns

DescribeProducersResult

DescribeProducersResult

DescribeProducers(Collection<TopicPartition>, DescribeProducersOptions)

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

Parameters

partitions Collection<TopicPartition>
options DescribeProducersOptions

Returns

DescribeProducersResult

DescribeProducersResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>)

DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> replicas)

Parameters

replicas Collection<TopicPartitionReplica>

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)

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

Parameters

replicas Collection<TopicPartitionReplica>
options DescribeReplicaLogDirsOptions

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeTopics(Collection<String>)

DescribeTopicsResult DescribeTopics(Collection<String> topicNames)

Parameters

topicNames Collection<String>

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTopics(Collection<String>, DescribeTopicsOptions)

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

Parameters

topicNames Collection<String>
options DescribeTopicsOptions

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTransactions(Collection<String>)

DescribeTransactionsResult DescribeTransactions(Collection<String> transactionalIds)

Parameters

transactionalIds Collection<String>

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeTransactions(Collection<String>, DescribeTransactionsOptions)

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

Parameters

transactionalIds Collection<String>
options DescribeTransactionsOptions

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeUserScramCredentials()

DescribeUserScramCredentialsResult DescribeUserScramCredentials()

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>)

DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> users)

Parameters

users List<String>

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions)

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

Parameters

users List<String>
options DescribeUserScramCredentialsOptions

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

ElectLeaders(ElectionType, Set<TopicPartition>)

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

Parameters

electionType ElectionType
partitions Set<TopicPartition>

Returns

ElectLeadersResult

ElectLeadersResult

ElectLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions)

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

Parameters

electionType ElectionType
partitions Set<TopicPartition>
options ElectLeadersOptions

Returns

ElectLeadersResult

ElectLeadersResult

ExpireDelegationToken(byte[])

ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac)

Parameters

hmac byte[]

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

ExpireDelegationToken(byte[], ExpireDelegationTokenOptions)

ExpireDelegationTokenResult ExpireDelegationToken(byte[] hmac, ExpireDelegationTokenOptions options)

Parameters

hmac byte[]
options ExpireDelegationTokenOptions

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

FenceProducers(Collection<String>)

FenceProducersResult FenceProducers(Collection<String> transactionalIds)

Parameters

transactionalIds Collection<String>

Returns

FenceProducersResult

FenceProducersResult

FenceProducers(Collection<String>, FenceProducersOptions)

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

Parameters

transactionalIds Collection<String>
options FenceProducersOptions

Returns

FenceProducersResult

FenceProducersResult

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

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

Parameters

configs Map<ConfigResource, Collection<AlterConfigOp>>

Returns

AlterConfigsResult

AlterConfigsResult

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

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

Parameters

configs Map<ConfigResource, Collection<AlterConfigOp>>
options AlterConfigsOptions

Returns

AlterConfigsResult

AlterConfigsResult

ListConsumerGroupOffsets(String)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId)

Parameters

groupId String

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)

Parameters

groupId String
options ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>)

ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> groupSpecs)

Parameters

groupSpecs Map<String, ListConsumerGroupOffsetsSpec>

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions)

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

Parameters

groupSpecs Map<String, ListConsumerGroupOffsetsSpec>
options ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroups()

ListConsumerGroupsResult ListConsumerGroups()

Returns

ListConsumerGroupsResult

ListConsumerGroupsResult

ListConsumerGroups(ListConsumerGroupsOptions)

ListConsumerGroupsResult ListConsumerGroups(ListConsumerGroupsOptions options)

Parameters

options ListConsumerGroupsOptions

Returns

ListConsumerGroupsResult

ListConsumerGroupsResult

ListOffsets(Map<TopicPartition, OffsetSpec>)

ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets)

Parameters

topicPartitionOffsets Map<TopicPartition, OffsetSpec>

Returns

ListOffsetsResult

ListOffsetsResult

ListOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)

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

Parameters

topicPartitionOffsets Map<TopicPartition, OffsetSpec>
options ListOffsetsOptions

Returns

ListOffsetsResult

ListOffsetsResult

ListPartitionReassignments()

ListPartitionReassignmentsResult ListPartitionReassignments()

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

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

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

Parameters

partitions Optional<Set<TopicPartition>>
options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Set<TopicPartition>)

ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> partitions)

Parameters

partitions Set<TopicPartition>

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions)

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

Parameters

partitions Set<TopicPartition>
options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(ListPartitionReassignmentsOptions)

ListPartitionReassignmentsResult ListPartitionReassignments(ListPartitionReassignmentsOptions options)

Parameters

options ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListTopics()

ListTopicsResult ListTopics()

Returns

ListTopicsResult

ListTopicsResult

ListTopics(ListTopicsOptions)

ListTopicsResult ListTopics(ListTopicsOptions options)

Parameters

options ListTopicsOptions

Returns

ListTopicsResult

ListTopicsResult

ListTransactions()

ListTransactionsResult ListTransactions()

Returns

ListTransactionsResult

ListTransactionsResult

ListTransactions(ListTransactionsOptions)

ListTransactionsResult ListTransactions(ListTransactionsOptions options)

Parameters

options ListTransactionsOptions

Returns

ListTransactionsResult

ListTransactionsResult

Metrics<T>()

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

Returns

Map<MetricName, T>

Map

Type Parameters

T

RemoveMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)

RemoveMembersFromConsumerGroupResult RemoveMembersFromConsumerGroup(String groupId, RemoveMembersFromConsumerGroupOptions options)

Parameters

groupId String
options RemoveMembersFromConsumerGroupOptions

Returns

RemoveMembersFromConsumerGroupResult

RemoveMembersFromConsumerGroupResult

RenewDelegationToken(byte[])

RenewDelegationTokenResult RenewDelegationToken(byte[] hmac)

Parameters

hmac byte[]

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

RenewDelegationToken(byte[], RenewDelegationTokenOptions)

RenewDelegationTokenResult RenewDelegationToken(byte[] hmac, RenewDelegationTokenOptions options)

Parameters

hmac byte[]
options RenewDelegationTokenOptions

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

UnregisterBroker(int)

UnregisterBrokerResult UnregisterBroker(int brokerId)

Parameters

brokerId int

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UnregisterBroker(int, UnregisterBrokerOptions)

UnregisterBrokerResult UnregisterBroker(int brokerId, UnregisterBrokerOptions options)

Parameters

brokerId int
options UnregisterBrokerOptions

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UpdateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions)

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

Parameters

featureUpdates Map<String, FeatureUpdate>
options UpdateFeaturesOptions

Returns

UpdateFeaturesResult

UpdateFeaturesResult