Table of Contents

Class DefaultReplicationPolicy

Namespace
Org.Apache.Kafka.Connect.Mirror
Assembly
MASES.KNet.dll
public class DefaultReplicationPolicy : JVMBridgeBase<DefaultReplicationPolicy>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IReplicationPolicy, IConfigurable
Inheritance
JVMBridgeBase
DefaultReplicationPolicy
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeBase<DefaultReplicationPolicy>.IsAssignableFrom(IJavaType)
JVMBridgeBase<DefaultReplicationPolicy>.IsAssignableFrom<T>()
JVMBridgeBase<DefaultReplicationPolicy>.Execute<T>(params T[])
JVMBridgeBase<DefaultReplicationPolicy>.DynBridgeClazz
JVMBridgeBase<DefaultReplicationPolicy>.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

Constructors

DefaultReplicationPolicy()

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

public DefaultReplicationPolicy()

DefaultReplicationPolicy(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 DefaultReplicationPolicy(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG

public static String INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG { get; }

Property Value

String

INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT

public static Boolean INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT { get; }

Property Value

Boolean

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

SEPARATOR_CONFIG

public static String SEPARATOR_CONFIG { get; }

Property Value

String

SEPARATOR_DEFAULT

public static String SEPARATOR_DEFAULT { get; }

Property Value

String

Methods

CheckpointsTopic(String)

public String CheckpointsTopic(String arg0)

Parameters

arg0 String

String

Returns

String

String

Configure(Map<String, object>)

public void Configure(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

FormatRemoteTopic(String, String)

public String FormatRemoteTopic(String arg0, String arg1)

Parameters

arg0 String

String

arg1 String

String

Returns

String

String

IsCheckpointsTopic(String)

public bool IsCheckpointsTopic(String arg0)

Parameters

arg0 String

String

Returns

bool

bool

IsMM2InternalTopic(String)

public bool IsMM2InternalTopic(String arg0)

Parameters

arg0 String

String

Returns

bool

bool

OffsetSyncsTopic(String)

public String OffsetSyncsTopic(String arg0)

Parameters

arg0 String

String

Returns

String

String

TopicSource(String)

public String TopicSource(String arg0)

Parameters

arg0 String

String

Returns

String

String

UpstreamTopic(String)

public String UpstreamTopic(String arg0)

Parameters

arg0 String

String

Returns

String

String

Operators

implicit operator Configurable(DefaultReplicationPolicy)

public static implicit operator Configurable(DefaultReplicationPolicy t)

Parameters

t DefaultReplicationPolicy

Returns

Configurable

implicit operator ReplicationPolicy(DefaultReplicationPolicy)

public static implicit operator ReplicationPolicy(DefaultReplicationPolicy t)

Parameters

t DefaultReplicationPolicy

Returns

ReplicationPolicy