Table of Contents

Class TopicCommand.TopicService

Namespace
Org.Apache.Kafka.Tools
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html

public class TopicCommand.TopicService : AutoCloseable, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IAutoCloseable
Inheritance
TopicCommand.TopicService
Implements

Constructors

TopicService(Properties, Optional<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#%3Cinit%3E(java.util.Properties,java.util.Optional)

public TopicService(Properties arg0, Optional<String> arg1)

Parameters

arg0 Properties

Properties

arg1 Optional<String>

Optional

TopicService(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public TopicService(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

TopicService(Admin)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#%3Cinit%3E(org.apache.kafka.clients.admin.Admin)

public TopicService(Admin arg0)

Parameters

arg0 Admin

Admin

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AlterTopic(TopicCommandOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#alterTopic(org.apache.kafka.tools.TopicCommand.TopicCommandOptions)

public void AlterTopic(TopicCommand.TopicCommandOptions arg0)

Parameters

arg0 TopicCommand.TopicCommandOptions

TopicCommand.TopicCommandOptions

Exceptions

ExecutionException
InterruptedException

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#close()

public void Close()

Exceptions

Exception

CreatePoolableInstance(Properties, Optional<String>)

HPA initializer for TopicService(Java.Util.Properties arg0, Java.Util.Optional%3CJava.Lang.String%3E arg1)

public static TopicCommand.TopicService CreatePoolableInstance(Properties arg0, Optional<String> arg1)

Parameters

arg0 Properties
arg1 Optional<String>

Returns

TopicCommand.TopicService

CreatePoolableInstance(Admin)

HPA initializer for TopicService(Org.Apache.Kafka.Clients.Admin.Admin arg0)

public static TopicCommand.TopicService CreatePoolableInstance(Admin arg0)

Parameters

arg0 Admin

Returns

TopicCommand.TopicService

CreateTopic(TopicCommandOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#createTopic(org.apache.kafka.tools.TopicCommand.TopicCommandOptions)

public void CreateTopic(TopicCommand.TopicCommandOptions arg0)

Parameters

arg0 TopicCommand.TopicCommandOptions

TopicCommand.TopicCommandOptions

Exceptions

Exception

DeleteTopic(TopicCommandOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#deleteTopic(org.apache.kafka.tools.TopicCommand.TopicCommandOptions)

public void DeleteTopic(TopicCommand.TopicCommandOptions arg0)

Parameters

arg0 TopicCommand.TopicCommandOptions

TopicCommand.TopicCommandOptions

Exceptions

ExecutionException
InterruptedException

DescribeTopic(TopicCommandOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#describeTopic(org.apache.kafka.tools.TopicCommand.TopicCommandOptions)

public void DescribeTopic(TopicCommand.TopicCommandOptions arg0)

Parameters

arg0 TopicCommand.TopicCommandOptions

TopicCommand.TopicCommandOptions

Exceptions

ExecutionException
InterruptedException

GetTopicIds(Uuid, bool)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#getTopicIds(org.apache.kafka.common.Uuid,boolean)

public List<Uuid> GetTopicIds(Uuid arg0, bool arg1)

Parameters

arg0 Uuid

Uuid

arg1 bool

bool

Returns

List<Uuid>

List

Exceptions

ExecutionException
InterruptedException

GetTopics(Optional<String>, bool)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#getTopics(java.util.Optional,boolean)

public List<String> GetTopics(Optional<String> arg0, bool arg1)

Parameters

arg0 Optional<String>

Optional

arg1 bool

bool

Returns

List<String>

List

Exceptions

ExecutionException
InterruptedException

ListAllReassignments(Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#listAllReassignments(java.util.Set)

public Map<TopicPartition, PartitionReassignment> ListAllReassignments(Set<TopicPartition> arg0)

Parameters

arg0 Set<TopicPartition>

Set

Returns

Map<TopicPartition, PartitionReassignment>

Map

ListTopics(TopicCommandOptions)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/TopicCommand.TopicService.html#listTopics(org.apache.kafka.tools.TopicCommand.TopicCommandOptions)

public void ListTopics(TopicCommand.TopicCommandOptions arg0)

Parameters

arg0 TopicCommand.TopicCommandOptions

TopicCommand.TopicCommandOptions

Exceptions

ExecutionException
InterruptedException
Edit this page