Table of Contents

Class ForwardingAdmin

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html

public class ForwardingAdmin : Admin, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IAdmin, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, IAutoCloseable
Inheritance
JVMBridgeBase
JVMBridgeBase<AutoCloseable>
ForwardingAdmin
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)
JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()
JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])
JVMBridgeBase<AutoCloseable>.DynBridgeClazz
JVMBridgeBase<AutoCloseable>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener
Extension Methods

Constructors

ForwardingAdmin()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public ForwardingAdmin()

ForwardingAdmin(Map<String, object>)

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

public ForwardingAdmin(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

ForwardingAdmin(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public ForwardingAdmin(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AbortTransaction(AbortTransactionSpec, AbortTransactionOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#abortTransaction-org.apache.kafka.clients.admin.AbortTransactionSpec-org.apache.kafka.clients.admin.AbortTransactionOptions-

public AbortTransactionResult AbortTransaction(AbortTransactionSpec arg0, AbortTransactionOptions arg1)

Parameters

arg0 AbortTransactionSpec

AbortTransactionSpec

arg1 AbortTransactionOptions

AbortTransactionOptions

Returns

AbortTransactionResult

AbortTransactionResult

AddRaftVoter(int, Uuid, Set<RaftVoterEndpoint>, AddRaftVoterOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#addRaftVoter-int-org.apache.kafka.common.Uuid-java.util.Set-org.apache.kafka.clients.admin.AddRaftVoterOptions-

public AddRaftVoterResult AddRaftVoter(int arg0, Uuid arg1, Set<RaftVoterEndpoint> arg2, AddRaftVoterOptions arg3)

Parameters

arg0 int

int

arg1 Uuid

Uuid

arg2 Set<RaftVoterEndpoint>

Set

arg3 AddRaftVoterOptions

AddRaftVoterOptions

Returns

AddRaftVoterResult

AddRaftVoterResult

AlterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#alterClientQuotas-java.util.Collection-org.apache.kafka.clients.admin.AlterClientQuotasOptions-

public AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> arg0, AlterClientQuotasOptions arg1)

Parameters

arg0 Collection<ClientQuotaAlteration>

Collection

arg1 AlterClientQuotasOptions

AlterClientQuotasOptions

Returns

AlterClientQuotasResult

AlterClientQuotasResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#alterConsumerGroupOffsets-java.lang.String-java.util.Map-org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions-

public AlterConsumerGroupOffsetsResult AlterConsumerGroupOffsets(String arg0, Map<TopicPartition, OffsetAndMetadata> arg1, AlterConsumerGroupOffsetsOptions arg2)

Parameters

arg0 String

String

arg1 Map<TopicPartition, OffsetAndMetadata>

Map

arg2 AlterConsumerGroupOffsetsOptions

AlterConsumerGroupOffsetsOptions

Returns

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsetsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#alterPartitionReassignments-java.util.Map-org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions-

public AlterPartitionReassignmentsResult AlterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>> arg0, AlterPartitionReassignmentsOptions arg1)

Parameters

arg0 Map<TopicPartition, Optional<NewPartitionReassignment>>

Map

arg1 AlterPartitionReassignmentsOptions

AlterPartitionReassignmentsOptions

Returns

AlterPartitionReassignmentsResult

AlterPartitionReassignmentsResult

AlterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#alterReplicaLogDirs-java.util.Map-org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions-

public AlterReplicaLogDirsResult AlterReplicaLogDirs(Map<TopicPartitionReplica, String> arg0, AlterReplicaLogDirsOptions arg1)

Parameters

arg0 Map<TopicPartitionReplica, String>

Map

arg1 AlterReplicaLogDirsOptions

AlterReplicaLogDirsOptions

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#alterUserScramCredentials-java.util.List-org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions-

public AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> arg0, AlterUserScramCredentialsOptions arg1)

Parameters

arg0 List<UserScramCredentialAlteration>

List

arg1 AlterUserScramCredentialsOptions

AlterUserScramCredentialsOptions

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

ClientInstanceId(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#clientInstanceId-java.time.Duration-

public Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

Close(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#close-java.time.Duration-

public void Close(Duration arg0)

Parameters

arg0 Duration

Duration

CreateAcls(Collection<AclBinding>, CreateAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#createAcls-java.util.Collection-org.apache.kafka.clients.admin.CreateAclsOptions-

public CreateAclsResult CreateAcls(Collection<AclBinding> arg0, CreateAclsOptions arg1)

Parameters

arg0 Collection<AclBinding>

Collection

arg1 CreateAclsOptions

CreateAclsOptions

Returns

CreateAclsResult

CreateAclsResult

CreateDelegationToken(CreateDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#createDelegationToken-org.apache.kafka.clients.admin.CreateDelegationTokenOptions-

public CreateDelegationTokenResult CreateDelegationToken(CreateDelegationTokenOptions arg0)

Parameters

arg0 CreateDelegationTokenOptions

CreateDelegationTokenOptions

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreatePartitions(Map<String, NewPartitions>, CreatePartitionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#createPartitions-java.util.Map-org.apache.kafka.clients.admin.CreatePartitionsOptions-

public CreatePartitionsResult CreatePartitions(Map<String, NewPartitions> arg0, CreatePartitionsOptions arg1)

Parameters

arg0 Map<String, NewPartitions>

Map

arg1 CreatePartitionsOptions

CreatePartitionsOptions

Returns

CreatePartitionsResult

CreatePartitionsResult

CreateTopics(Collection<NewTopic>, CreateTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#createTopics-java.util.Collection-org.apache.kafka.clients.admin.CreateTopicsOptions-

public CreateTopicsResult CreateTopics(Collection<NewTopic> arg0, CreateTopicsOptions arg1)

Parameters

arg0 Collection<NewTopic>

Collection

arg1 CreateTopicsOptions

CreateTopicsOptions

Returns

CreateTopicsResult

CreateTopicsResult

DeleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#deleteAcls-java.util.Collection-org.apache.kafka.clients.admin.DeleteAclsOptions-

public DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> arg0, DeleteAclsOptions arg1)

Parameters

arg0 Collection<AclBindingFilter>

Collection

arg1 DeleteAclsOptions

DeleteAclsOptions

Returns

DeleteAclsResult

DeleteAclsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#deleteConsumerGroupOffsets-java.lang.String-java.util.Set-org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions-

public DeleteConsumerGroupOffsetsResult DeleteConsumerGroupOffsets(String arg0, Set<TopicPartition> arg1, DeleteConsumerGroupOffsetsOptions arg2)

Parameters

arg0 String

String

arg1 Set<TopicPartition>

Set

arg2 DeleteConsumerGroupOffsetsOptions

DeleteConsumerGroupOffsetsOptions

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#deleteConsumerGroups-java.util.Collection-org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions-

public DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> arg0, DeleteConsumerGroupsOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 DeleteConsumerGroupsOptions

DeleteConsumerGroupsOptions

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#deleteRecords-java.util.Map-org.apache.kafka.clients.admin.DeleteRecordsOptions-

public DeleteRecordsResult DeleteRecords(Map<TopicPartition, RecordsToDelete> arg0, DeleteRecordsOptions arg1)

Parameters

arg0 Map<TopicPartition, RecordsToDelete>

Map

arg1 DeleteRecordsOptions

DeleteRecordsOptions

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteTopics(TopicCollection, DeleteTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#deleteTopics-org.apache.kafka.common.TopicCollection-org.apache.kafka.clients.admin.DeleteTopicsOptions-

public DeleteTopicsResult DeleteTopics(TopicCollection arg0, DeleteTopicsOptions arg1)

Parameters

arg0 TopicCollection

TopicCollection

arg1 DeleteTopicsOptions

DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DescribeAcls(AclBindingFilter, DescribeAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeAcls-org.apache.kafka.common.acl.AclBindingFilter-org.apache.kafka.clients.admin.DescribeAclsOptions-

public DescribeAclsResult DescribeAcls(AclBindingFilter arg0, DescribeAclsOptions arg1)

Parameters

arg0 AclBindingFilter

AclBindingFilter

arg1 DescribeAclsOptions

DescribeAclsOptions

Returns

DescribeAclsResult

DescribeAclsResult

DescribeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeClientQuotas-org.apache.kafka.common.quota.ClientQuotaFilter-org.apache.kafka.clients.admin.DescribeClientQuotasOptions-

public DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter arg0, DescribeClientQuotasOptions arg1)

Parameters

arg0 ClientQuotaFilter

ClientQuotaFilter

arg1 DescribeClientQuotasOptions

DescribeClientQuotasOptions

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeCluster(DescribeClusterOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeCluster-org.apache.kafka.clients.admin.DescribeClusterOptions-

public DescribeClusterResult DescribeCluster(DescribeClusterOptions arg0)

Parameters

arg0 DescribeClusterOptions

DescribeClusterOptions

Returns

DescribeClusterResult

DescribeClusterResult

DescribeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeConfigs-java.util.Collection-org.apache.kafka.clients.admin.DescribeConfigsOptions-

public DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> arg0, DescribeConfigsOptions arg1)

Parameters

arg0 Collection<ConfigResource>

Collection

arg1 DescribeConfigsOptions

DescribeConfigsOptions

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeConsumerGroups-java.util.Collection-org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions-

public DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> arg0, DescribeConsumerGroupsOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 DescribeConsumerGroupsOptions

DescribeConsumerGroupsOptions

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeDelegationToken(DescribeDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeDelegationToken-org.apache.kafka.clients.admin.DescribeDelegationTokenOptions-

public DescribeDelegationTokenResult DescribeDelegationToken(DescribeDelegationTokenOptions arg0)

Parameters

arg0 DescribeDelegationTokenOptions

DescribeDelegationTokenOptions

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeFeatures(DescribeFeaturesOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeFeatures-org.apache.kafka.clients.admin.DescribeFeaturesOptions-

public DescribeFeaturesResult DescribeFeatures(DescribeFeaturesOptions arg0)

Parameters

arg0 DescribeFeaturesOptions

DescribeFeaturesOptions

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeLogDirs(Collection<Integer>, DescribeLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeLogDirs-java.util.Collection-org.apache.kafka.clients.admin.DescribeLogDirsOptions-

public DescribeLogDirsResult DescribeLogDirs(Collection<Integer> arg0, DescribeLogDirsOptions arg1)

Parameters

arg0 Collection<Integer>

Collection

arg1 DescribeLogDirsOptions

DescribeLogDirsOptions

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeMetadataQuorum(DescribeMetadataQuorumOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeMetadataQuorum-org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions-

public DescribeMetadataQuorumResult DescribeMetadataQuorum(DescribeMetadataQuorumOptions arg0)

Parameters

arg0 DescribeMetadataQuorumOptions

DescribeMetadataQuorumOptions

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeProducers(Collection<TopicPartition>, DescribeProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeProducers-java.util.Collection-org.apache.kafka.clients.admin.DescribeProducersOptions-

public DescribeProducersResult DescribeProducers(Collection<TopicPartition> arg0, DescribeProducersOptions arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 DescribeProducersOptions

DescribeProducersOptions

Returns

DescribeProducersResult

DescribeProducersResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeReplicaLogDirs-java.util.Collection-org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions-

public DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> arg0, DescribeReplicaLogDirsOptions arg1)

Parameters

arg0 Collection<TopicPartitionReplica>

Collection

arg1 DescribeReplicaLogDirsOptions

DescribeReplicaLogDirsOptions

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeTopics(TopicCollection, DescribeTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeTopics-org.apache.kafka.common.TopicCollection-org.apache.kafka.clients.admin.DescribeTopicsOptions-

public DescribeTopicsResult DescribeTopics(TopicCollection arg0, DescribeTopicsOptions arg1)

Parameters

arg0 TopicCollection

TopicCollection

arg1 DescribeTopicsOptions

DescribeTopicsOptions

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTransactions(Collection<String>, DescribeTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeTransactions-java.util.Collection-org.apache.kafka.clients.admin.DescribeTransactionsOptions-

public DescribeTransactionsResult DescribeTransactions(Collection<String> arg0, DescribeTransactionsOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 DescribeTransactionsOptions

DescribeTransactionsOptions

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#describeUserScramCredentials-java.util.List-org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions-

public DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> arg0, DescribeUserScramCredentialsOptions arg1)

Parameters

arg0 List<String>

List

arg1 DescribeUserScramCredentialsOptions

DescribeUserScramCredentialsOptions

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

ElectLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#electLeaders-org.apache.kafka.common.ElectionType-java.util.Set-org.apache.kafka.clients.admin.ElectLeadersOptions-

public ElectLeadersResult ElectLeaders(ElectionType arg0, Set<TopicPartition> arg1, ElectLeadersOptions arg2)

Parameters

arg0 ElectionType

ElectionType

arg1 Set<TopicPartition>

Set

arg2 ElectLeadersOptions

ElectLeadersOptions

Returns

ElectLeadersResult

ElectLeadersResult

ExpireDelegationToken(byte[], ExpireDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#expireDelegationToken-byte[]-org.apache.kafka.clients.admin.ExpireDelegationTokenOptions-

public ExpireDelegationTokenResult ExpireDelegationToken(byte[] arg0, ExpireDelegationTokenOptions arg1)

Parameters

arg0 byte[]

byte

arg1 ExpireDelegationTokenOptions

ExpireDelegationTokenOptions

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

FenceProducers(Collection<String>, FenceProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#fenceProducers-java.util.Collection-org.apache.kafka.clients.admin.FenceProducersOptions-

public FenceProducersResult FenceProducers(Collection<String> arg0, FenceProducersOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 FenceProducersOptions

FenceProducersOptions

Returns

FenceProducersResult

FenceProducersResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#incrementalAlterConfigs-java.util.Map-org.apache.kafka.clients.admin.AlterConfigsOptions-

public AlterConfigsResult IncrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>> arg0, AlterConfigsOptions arg1)

Parameters

arg0 Map<ConfigResource, Collection<AlterConfigOp>>

Map

arg1 AlterConfigsOptions

AlterConfigsOptions

Returns

AlterConfigsResult

AlterConfigsResult

ListClientMetricsResources(ListClientMetricsResourcesOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listClientMetricsResources-org.apache.kafka.clients.admin.ListClientMetricsResourcesOptions-

public ListClientMetricsResourcesResult ListClientMetricsResources(ListClientMetricsResourcesOptions arg0)

Parameters

arg0 ListClientMetricsResourcesOptions

ListClientMetricsResourcesOptions

Returns

ListClientMetricsResourcesResult

ListClientMetricsResourcesResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listConsumerGroupOffsets-java.util.Map-org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions-

public ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec> arg0, ListConsumerGroupOffsetsOptions arg1)

Parameters

arg0 Map<String, ListConsumerGroupOffsetsSpec>

Map

arg1 ListConsumerGroupOffsetsOptions

ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroups(ListConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listConsumerGroups-org.apache.kafka.clients.admin.ListConsumerGroupsOptions-

public ListConsumerGroupsResult ListConsumerGroups(ListConsumerGroupsOptions arg0)

Parameters

arg0 ListConsumerGroupsOptions

ListConsumerGroupsOptions

Returns

ListConsumerGroupsResult

ListConsumerGroupsResult

ListOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listOffsets-java.util.Map-org.apache.kafka.clients.admin.ListOffsetsOptions-

public ListOffsetsResult ListOffsets(Map<TopicPartition, OffsetSpec> arg0, ListOffsetsOptions arg1)

Parameters

arg0 Map<TopicPartition, OffsetSpec>

Map

arg1 ListOffsetsOptions

ListOffsetsOptions

Returns

ListOffsetsResult

ListOffsetsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listPartitionReassignments-java.util.Optional-org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions-

public ListPartitionReassignmentsResult ListPartitionReassignments(Optional<Set<TopicPartition>> arg0, ListPartitionReassignmentsOptions arg1)

Parameters

arg0 Optional<Set<TopicPartition>>

Optional

arg1 ListPartitionReassignmentsOptions

ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListTopics(ListTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listTopics-org.apache.kafka.clients.admin.ListTopicsOptions-

public ListTopicsResult ListTopics(ListTopicsOptions arg0)

Parameters

arg0 ListTopicsOptions

ListTopicsOptions

Returns

ListTopicsResult

ListTopicsResult

ListTransactions(ListTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#listTransactions-org.apache.kafka.clients.admin.ListTransactionsOptions-

public ListTransactionsResult ListTransactions(ListTransactionsOptions arg0)

Parameters

arg0 ListTransactionsOptions

ListTransactionsOptions

Returns

ListTransactionsResult

ListTransactionsResult

Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#metrics--

public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : Metric

Returns

Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>

Map

Type Parameters

ReturnExtendsOrg_Apache_Kafka_Common_Metric

Metric

RemoveMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#removeMembersFromConsumerGroup-java.lang.String-org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions-

public RemoveMembersFromConsumerGroupResult RemoveMembersFromConsumerGroup(String arg0, RemoveMembersFromConsumerGroupOptions arg1)

Parameters

arg0 String

String

arg1 RemoveMembersFromConsumerGroupOptions

RemoveMembersFromConsumerGroupOptions

Returns

RemoveMembersFromConsumerGroupResult

RemoveMembersFromConsumerGroupResult

RemoveRaftVoter(int, Uuid, RemoveRaftVoterOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#removeRaftVoter-int-org.apache.kafka.common.Uuid-org.apache.kafka.clients.admin.RemoveRaftVoterOptions-

public RemoveRaftVoterResult RemoveRaftVoter(int arg0, Uuid arg1, RemoveRaftVoterOptions arg2)

Parameters

arg0 int

int

arg1 Uuid

Uuid

arg2 RemoveRaftVoterOptions

RemoveRaftVoterOptions

Returns

RemoveRaftVoterResult

RemoveRaftVoterResult

RenewDelegationToken(byte[], RenewDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#renewDelegationToken-byte[]-org.apache.kafka.clients.admin.RenewDelegationTokenOptions-

public RenewDelegationTokenResult RenewDelegationToken(byte[] arg0, RenewDelegationTokenOptions arg1)

Parameters

arg0 byte[]

byte

arg1 RenewDelegationTokenOptions

RenewDelegationTokenOptions

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

UnregisterBroker(int, UnregisterBrokerOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#unregisterBroker-int-org.apache.kafka.clients.admin.UnregisterBrokerOptions-

public UnregisterBrokerResult UnregisterBroker(int arg0, UnregisterBrokerOptions arg1)

Parameters

arg0 int

int

arg1 UnregisterBrokerOptions

UnregisterBrokerOptions

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UpdateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/ForwardingAdmin.html#updateFeatures-java.util.Map-org.apache.kafka.clients.admin.UpdateFeaturesOptions-

public UpdateFeaturesResult UpdateFeatures(Map<String, FeatureUpdate> arg0, UpdateFeaturesOptions arg1)

Parameters

arg0 Map<String, FeatureUpdate>

Map

arg1 UpdateFeaturesOptions

UpdateFeaturesOptions

Returns

UpdateFeaturesResult

UpdateFeaturesResult

Edit this page