Table of Contents

Class TopologyConfig

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

TopologyConfig()

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

public TopologyConfig()

TopologyConfig(String, StreamsConfig, Properties)

public TopologyConfig(String arg0, StreamsConfig arg1, Properties arg2)

Parameters

arg0 String

String

arg1 StreamsConfig

StreamsConfig

arg2 Properties

Properties

TopologyConfig(StreamsConfig)

public TopologyConfig(StreamsConfig arg0)

Parameters

arg0 StreamsConfig

StreamsConfig

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

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

GetTaskConfig

public TopologyConfig.TaskConfig GetTaskConfig { get; }

Property Value

TopologyConfig.TaskConfig

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

applicationConfigs

public StreamsConfig applicationConfigs { get; }

Property Value

StreamsConfig

cacheSize

public long cacheSize { get; }

Property Value

long

deserializationExceptionHandlerSupplier

public Supplier deserializationExceptionHandlerSupplier { get; }

Property Value

Supplier

dslStoreSuppliers

public Class dslStoreSuppliers { get; }

Property Value

Class

eosEnabled

public bool eosEnabled { get; }

Property Value

bool

maxBufferedSize

public int maxBufferedSize { get; }

Property Value

int

maxTaskIdleMs

public long maxTaskIdleMs { get; }

Property Value

long

processingExceptionHandlerSupplier

public Supplier processingExceptionHandlerSupplier { get; }

Property Value

Supplier

storeType

public String storeType { get; }

Property Value

String

taskTimeoutMs

public long taskTimeoutMs { get; }

Property Value

long

timestampExtractorSupplier

public Supplier timestampExtractorSupplier { get; }

Property Value

Supplier

topologyName

public String topologyName { get; }

Property Value

String

topologyOverrides

public Properties topologyOverrides { get; }

Property Value

Properties

Methods

IsNamedTopology()

public bool IsNamedTopology()

Returns

bool

bool

ResolveDslStoreSuppliers()

public Optional<DslStoreSuppliers> ResolveDslStoreSuppliers()

Returns

Optional<DslStoreSuppliers>

Optional