Class Admin

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/Admin.html

public class Admin : AutoCloseable, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IAdmin, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, IAutoCloseable

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AutoCloseable>

AutoCloseable

Admin

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IJVMBridgeBaseStatic

IAdmin

IJVMBridgeBase

IJVMBridgeDefinition

IDisposable

IAutoCloseable

Derived

AdminClient

ForwardingAdmin

Inherited Members

JVMBridgeBase<AutoCloseable>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SGetField(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetField(string)

JVMBridgeBase<AutoCloseable>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetField<TReturn>(string)

JVMBridgeBase<AutoCloseable>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<AutoCloseable>.SSetField(IJavaType, string, object)

JVMBridgeBase<AutoCloseable>.SSetField(string, object)

JVMBridgeBase<AutoCloseable>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<AutoCloseable>.SSetField<TValue>(string, TValue)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom(string)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()

JVMBridgeBase<AutoCloseable>.New(params object[])

JVMBridgeBase<AutoCloseable>.NewWithSignature(string, params object[])

JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])

JVMBridgeBase<AutoCloseable>.DynBridgeClazz

JVMBridgeBase<AutoCloseable>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Dispose()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

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.ListConsumerGroupsAsync(IAdmin)

KafkaAdminClientExtensions.ListConsumerGroupsAsync(IAdmin, ListConsumerGroupsOptions)

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)

Constructors

Admin()

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

[Obsolete("Admin class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Admin()

Admin(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

[Obsolete("Admin class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Admin(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)

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

public AbortTransactionResult AbortTransaction(AbortTransactionSpec arg0)

Parameters

arg0 AbortTransactionSpec

AbortTransactionSpec

Returns

AbortTransactionResult

AbortTransactionResult

AbortTransaction(AbortTransactionSpec, AbortTransactionOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 int

int

arg1 Uuid

Uuid

arg2 Set<RaftVoterEndpoint>

Set

Returns

AddRaftVoterResult

AddRaftVoterResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public AlterClientQuotasResult AlterClientQuotas(Collection<ClientQuotaAlteration> arg0)

Parameters

arg0 Collection<ClientQuotaAlteration>

Collection

Returns

AlterClientQuotasResult

AlterClientQuotasResult

AlterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 String

String

arg1 Map<TopicPartition, OffsetAndMetadata>

Map

Returns

AlterConsumerGroupOffsetsResult

AlterConsumerGroupOffsetsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>>)

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

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

Parameters

arg0 Map<TopicPartition, Optional<NewPartitionReassignment>>

Map

Returns

AlterPartitionReassignmentsResult

AlterPartitionReassignmentsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 Map<TopicPartitionReplica, String>

Map

Returns

AlterReplicaLogDirsResult

AlterReplicaLogDirsResult

AlterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public AlterUserScramCredentialsResult AlterUserScramCredentials(List<UserScramCredentialAlteration> arg0)

Parameters

arg0 List<UserScramCredentialAlteration>

List

Returns

AlterUserScramCredentialsResult

AlterUserScramCredentialsResult

AlterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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/Admin.html#clientInstanceId-java.time.Duration-

public Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

Close()

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

public void Close()

Close(Duration)

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

public void Close(Duration arg0)

Parameters

arg0 Duration

Duration

Create(Map<String, object>)

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

public static Admin Create(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

Returns

Admin

Admin

Create(Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.html#create-java.util.Properties-

public static Admin Create(Properties arg0)

Parameters

arg0 Properties

Properties

Returns

Admin

Admin

CreateAcls(Collection<AclBinding>)

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

public CreateAclsResult CreateAcls(Collection<AclBinding> arg0)

Parameters

arg0 Collection<AclBinding>

Collection

Returns

CreateAclsResult

CreateAclsResult

CreateAcls(Collection<AclBinding>, CreateAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public CreateDelegationTokenResult CreateDelegationToken()

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreateDelegationToken(CreateDelegationTokenOptions)

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

public CreateDelegationTokenResult CreateDelegationToken(CreateDelegationTokenOptions arg0)

Parameters

arg0 CreateDelegationTokenOptions

CreateDelegationTokenOptions

Returns

CreateDelegationTokenResult

CreateDelegationTokenResult

CreatePartitions(Map<String, NewPartitions>)

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

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

Parameters

arg0 Map<String, NewPartitions>

Map

Returns

CreatePartitionsResult

CreatePartitionsResult

CreatePartitions(Map<String, NewPartitions>, CreatePartitionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public CreateTopicsResult CreateTopics(Collection<NewTopic> arg0)

Parameters

arg0 Collection<NewTopic>

Collection

Returns

CreateTopicsResult

CreateTopicsResult

CreateTopics(Collection<NewTopic>, CreateTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public DeleteAclsResult DeleteAcls(Collection<AclBindingFilter> arg0)

Parameters

arg0 Collection<AclBindingFilter>

Collection

Returns

DeleteAclsResult

DeleteAclsResult

DeleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 String

String

arg1 Set<TopicPartition>

Set

Returns

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsetsResult

DeleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public DeleteConsumerGroupsResult DeleteConsumerGroups(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

DeleteConsumerGroupsResult

DeleteConsumerGroupsResult

DeleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 Map<TopicPartition, RecordsToDelete>

Map

Returns

DeleteRecordsResult

DeleteRecordsResult

DeleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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(Collection<String>)

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

public DeleteTopicsResult DeleteTopics(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(Collection<String>, DeleteTopicsOptions)

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

public DeleteTopicsResult DeleteTopics(Collection<String> arg0, DeleteTopicsOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 DeleteTopicsOptions

DeleteTopicsOptions

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection)

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

public DeleteTopicsResult DeleteTopics(TopicCollection arg0)

Parameters

arg0 TopicCollection

TopicCollection

Returns

DeleteTopicsResult

DeleteTopicsResult

DeleteTopics(TopicCollection, DeleteTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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)

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

public DescribeAclsResult DescribeAcls(AclBindingFilter arg0)

Parameters

arg0 AclBindingFilter

AclBindingFilter

Returns

DescribeAclsResult

DescribeAclsResult

DescribeAcls(AclBindingFilter, DescribeAclsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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)

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

public DescribeClientQuotasResult DescribeClientQuotas(ClientQuotaFilter arg0)

Parameters

arg0 ClientQuotaFilter

ClientQuotaFilter

Returns

DescribeClientQuotasResult

DescribeClientQuotasResult

DescribeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public DescribeClusterResult DescribeCluster()

Returns

DescribeClusterResult

DescribeClusterResult

DescribeCluster(DescribeClusterOptions)

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

public DescribeClusterResult DescribeCluster(DescribeClusterOptions arg0)

Parameters

arg0 DescribeClusterOptions

DescribeClusterOptions

Returns

DescribeClusterResult

DescribeClusterResult

DescribeConfigs(Collection<ConfigResource>)

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

public DescribeConfigsResult DescribeConfigs(Collection<ConfigResource> arg0)

Parameters

arg0 Collection<ConfigResource>

Collection

Returns

DescribeConfigsResult

DescribeConfigsResult

DescribeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public DescribeConsumerGroupsResult DescribeConsumerGroups(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

DescribeConsumerGroupsResult

DescribeConsumerGroupsResult

DescribeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public DescribeDelegationTokenResult DescribeDelegationToken()

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeDelegationToken(DescribeDelegationTokenOptions)

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

public DescribeDelegationTokenResult DescribeDelegationToken(DescribeDelegationTokenOptions arg0)

Parameters

arg0 DescribeDelegationTokenOptions

DescribeDelegationTokenOptions

Returns

DescribeDelegationTokenResult

DescribeDelegationTokenResult

DescribeFeatures()

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

public DescribeFeaturesResult DescribeFeatures()

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeFeatures(DescribeFeaturesOptions)

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

public DescribeFeaturesResult DescribeFeatures(DescribeFeaturesOptions arg0)

Parameters

arg0 DescribeFeaturesOptions

DescribeFeaturesOptions

Returns

DescribeFeaturesResult

DescribeFeaturesResult

DescribeLogDirs(Collection<Integer>)

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

public DescribeLogDirsResult DescribeLogDirs(Collection<Integer> arg0)

Parameters

arg0 Collection<Integer>

Collection

Returns

DescribeLogDirsResult

DescribeLogDirsResult

DescribeLogDirs(Collection<Integer>, DescribeLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public DescribeMetadataQuorumResult DescribeMetadataQuorum()

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeMetadataQuorum(DescribeMetadataQuorumOptions)

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

public DescribeMetadataQuorumResult DescribeMetadataQuorum(DescribeMetadataQuorumOptions arg0)

Parameters

arg0 DescribeMetadataQuorumOptions

DescribeMetadataQuorumOptions

Returns

DescribeMetadataQuorumResult

DescribeMetadataQuorumResult

DescribeProducers(Collection<TopicPartition>)

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

public DescribeProducersResult DescribeProducers(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

DescribeProducersResult

DescribeProducersResult

DescribeProducers(Collection<TopicPartition>, DescribeProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public DescribeReplicaLogDirsResult DescribeReplicaLogDirs(Collection<TopicPartitionReplica> arg0)

Parameters

arg0 Collection<TopicPartitionReplica>

Collection

Returns

DescribeReplicaLogDirsResult

DescribeReplicaLogDirsResult

DescribeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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(Collection<String>)

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

public DescribeTopicsResult DescribeTopics(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTopics(Collection<String>, DescribeTopicsOptions)

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

public DescribeTopicsResult DescribeTopics(Collection<String> arg0, DescribeTopicsOptions arg1)

Parameters

arg0 Collection<String>

Collection

arg1 DescribeTopicsOptions

DescribeTopicsOptions

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTopics(TopicCollection)

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

public DescribeTopicsResult DescribeTopics(TopicCollection arg0)

Parameters

arg0 TopicCollection

TopicCollection

Returns

DescribeTopicsResult

DescribeTopicsResult

DescribeTopics(TopicCollection, DescribeTopicsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public DescribeTransactionsResult DescribeTransactions(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

DescribeTransactionsResult

DescribeTransactionsResult

DescribeTransactions(Collection<String>, DescribeTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public DescribeUserScramCredentialsResult DescribeUserScramCredentials()

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>)

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

public DescribeUserScramCredentialsResult DescribeUserScramCredentials(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

DescribeUserScramCredentialsResult

DescribeUserScramCredentialsResult

DescribeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

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

Parameters

arg0 ElectionType

ElectionType

arg1 Set<TopicPartition>

Set

Returns

ElectLeadersResult

ElectLeadersResult

ElectLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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[])

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

public ExpireDelegationTokenResult ExpireDelegationToken(byte[] arg0)

Parameters

arg0 byte[]

byte

Returns

ExpireDelegationTokenResult

ExpireDelegationTokenResult

ExpireDelegationToken(byte[], ExpireDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>)

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

public FenceProducersResult FenceProducers(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

FenceProducersResult

FenceProducersResult

FenceProducers(Collection<String>, FenceProducersOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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>>)

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

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

Parameters

arg0 Map<ConfigResource, Collection<AlterConfigOp>>

Map

Returns

AlterConfigsResult

AlterConfigsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public ListClientMetricsResourcesResult ListClientMetricsResources()

Returns

ListClientMetricsResourcesResult

ListClientMetricsResourcesResult

ListClientMetricsResources(ListClientMetricsResourcesOptions)

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

public ListClientMetricsResourcesResult ListClientMetricsResources(ListClientMetricsResourcesOptions arg0)

Parameters

arg0 ListClientMetricsResourcesOptions

ListClientMetricsResourcesOptions

Returns

ListClientMetricsResourcesResult

ListClientMetricsResourcesResult

ListConsumerGroupOffsets(String)

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

public ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String arg0)

Parameters

arg0 String

String

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)

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

public ListConsumerGroupOffsetsResult ListConsumerGroupOffsets(String arg0, ListConsumerGroupOffsetsOptions arg1)

Parameters

arg0 String

String

arg1 ListConsumerGroupOffsetsOptions

ListConsumerGroupOffsetsOptions

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>)

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

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

Parameters

arg0 Map<String, ListConsumerGroupOffsetsSpec>

Map

Returns

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsetsResult

ListConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public ListConsumerGroupsResult ListConsumerGroups()

Returns

ListConsumerGroupsResult

ListConsumerGroupsResult

ListConsumerGroups(ListConsumerGroupsOptions)

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

public ListConsumerGroupsResult ListConsumerGroups(ListConsumerGroupsOptions arg0)

Parameters

arg0 ListConsumerGroupsOptions

ListConsumerGroupsOptions

Returns

ListConsumerGroupsResult

ListConsumerGroupsResult

ListOffsets(Map<TopicPartition, OffsetSpec>)

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

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

Parameters

arg0 Map<TopicPartition, OffsetSpec>

Map

Returns

ListOffsetsResult

ListOffsetsResult

ListOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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()

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

public ListPartitionReassignmentsResult ListPartitionReassignments()

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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

ListPartitionReassignments(Set<TopicPartition>)

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

public ListPartitionReassignmentsResult ListPartitionReassignments(Set<TopicPartition> arg0)

Parameters

arg0 Set<TopicPartition>

Set

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions)

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

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

Parameters

arg0 Set<TopicPartition>

Set

arg1 ListPartitionReassignmentsOptions

ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListPartitionReassignments(ListPartitionReassignmentsOptions)

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

public ListPartitionReassignmentsResult ListPartitionReassignments(ListPartitionReassignmentsOptions arg0)

Parameters

arg0 ListPartitionReassignmentsOptions

ListPartitionReassignmentsOptions

Returns

ListPartitionReassignmentsResult

ListPartitionReassignmentsResult

ListTopics()

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

public ListTopicsResult ListTopics()

Returns

ListTopicsResult

ListTopicsResult

ListTopics(ListTopicsOptions)

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

public ListTopicsResult ListTopics(ListTopicsOptions arg0)

Parameters

arg0 ListTopicsOptions

ListTopicsOptions

Returns

ListTopicsResult

ListTopicsResult

ListTransactions()

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

public ListTransactionsResult ListTransactions()

Returns

ListTransactionsResult

ListTransactionsResult

ListTransactions(ListTransactionsOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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/Admin.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/Admin.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)

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

public RemoveRaftVoterResult RemoveRaftVoter(int arg0, Uuid arg1)

Parameters

arg0 int

int

arg1 Uuid

Uuid

Returns

RemoveRaftVoterResult

RemoveRaftVoterResult

RemoveRaftVoter(int, Uuid, RemoveRaftVoterOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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[])

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

public RenewDelegationTokenResult RenewDelegationToken(byte[] arg0)

Parameters

arg0 byte[]

byte

Returns

RenewDelegationTokenResult

RenewDelegationTokenResult

RenewDelegationToken(byte[], RenewDelegationTokenOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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)

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

public UnregisterBrokerResult UnregisterBroker(int arg0)

Parameters

arg0 int

int

Returns

UnregisterBrokerResult

UnregisterBrokerResult

UnregisterBroker(int, UnregisterBrokerOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/admin/Admin.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/Admin.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