Class TopicAdmin
public class TopicAdmin : AutoCloseable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IAutoCloseable- Inheritance
-
TopicAdmin
- Implements
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])
Constructors
TopicAdmin()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public TopicAdmin()TopicAdmin(Map<String, object>)
public TopicAdmin(Map<String, object> arg0)Parameters
TopicAdmin(Map<String, object>, Admin)
public TopicAdmin(Map<String, object> arg0, Admin arg1)Parameters
TopicAdmin(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 TopicAdmin(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
EMPTY_CREATION
public static TopicAdmin.TopicCreationResponse EMPTY_CREATION { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
NO_PARTITIONS
public static int NO_PARTITIONS { get; }Property Value
NO_REPLICATION_FACTOR
public static short NO_REPLICATION_FACTOR { get; }Property Value
Methods
Close()
public void Close()Close(Duration)
public void Close(Duration arg0)Parameters
CreateOrFindTopic(NewTopic)
public bool CreateOrFindTopic(NewTopic arg0)Parameters
Returns
CreateOrFindTopics(params NewTopic[])
public TopicAdmin.TopicCreationResponse CreateOrFindTopics(params NewTopic[] arg0)Parameters
Returns
CreateTopic(NewTopic)
public bool CreateTopic(NewTopic arg0)Parameters
Returns
CreateTopics(params NewTopic[])
public Set<String> CreateTopics(params NewTopic[] arg0)Parameters
Returns
CreateTopicsWithRetry(NewTopic, long, long, Time)
public Set<String> CreateTopicsWithRetry(NewTopic arg0, long arg1, long arg2, Time arg3)Parameters
Returns
DefineTopic(String)
public static TopicAdmin.NewTopicBuilder DefineTopic(String arg0)Parameters
Returns
DescribeTopicConfig(String)
public Config DescribeTopicConfig(String arg0)Parameters
Returns
DescribeTopicConfigs(params String[])
public Map<String, Config> DescribeTopicConfigs(params String[] arg0)Parameters
Returns
DescribeTopics(params String[])
public Map<String, TopicDescription> DescribeTopics(params String[] arg0)Parameters
Returns
EndOffsets(Set<TopicPartition>)
public Map<TopicPartition, Long> EndOffsets(Set<TopicPartition> arg0)Parameters
arg0Set<TopicPartition>
Returns
RetryEndOffsets(Set<TopicPartition>, Duration, long)
public Map<TopicPartition, Long> RetryEndOffsets(Set<TopicPartition> arg0, Duration arg1, long arg2)Parameters
Returns
TopicCleanupPolicy(String)
public Set<String> TopicCleanupPolicy(String arg0)Parameters
Returns
VerifyTopicCleanupPolicyOnlyCompact(String, String, String)
public bool VerifyTopicCleanupPolicyOnlyCompact(String arg0, String arg1, String arg2)