Table of Contents

Class Topology

Namespace
Org.Apache.Kafka.Streams
Assembly
MASES.KNet.dll
public class Topology : JVMBridgeBase<Topology>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
Topology
Implements
Inherited Members

Constructors

Topology()

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

public Topology()

Topology(TopologyConfig)

public Topology(TopologyConfig arg0)

Parameters

arg0 TopologyConfig

TopologyConfig

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

Parameters

args object[]

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 Closeable

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

AddGlobalStore<KIn, VIn>(StoreBuilder, String, Deserializer<KIn>, Deserializer<VIn>, String, String, ProcessorSupplier<KIn, VIn, Void, Void>)

public Topology AddGlobalStore<KIn, VIn>(StoreBuilder arg0, String arg1, Deserializer<KIn> arg2, Deserializer<VIn> arg3, String arg4, String arg5, ProcessorSupplier<KIn, VIn, Void, Void> arg6)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String

String

arg2 Deserializer<KIn>

Deserializer

arg3 Deserializer<VIn>

Deserializer

arg4 String

String

arg5 String

String

arg6 ProcessorSupplier<KIn, VIn, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

KIn
VIn

AddGlobalStore<KIn, VIn>(StoreBuilder, String, TimestampExtractor, Deserializer<KIn>, Deserializer<VIn>, String, String, ProcessorSupplier<KIn, VIn, Void, Void>)

public Topology AddGlobalStore<KIn, VIn>(StoreBuilder arg0, String arg1, TimestampExtractor arg2, Deserializer<KIn> arg3, Deserializer<VIn> arg4, String arg5, String arg6, ProcessorSupplier<KIn, VIn, Void, Void> arg7)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<KIn>

Deserializer

arg4 Deserializer<VIn>

Deserializer

arg5 String

String

arg6 String

String

arg7 ProcessorSupplier<KIn, VIn, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

KIn
VIn

AddProcessor<KIn, VIn, KOut, VOut>(String, ProcessorSupplier<KIn, VIn, KOut, VOut>, params String[])

public Topology AddProcessor<KIn, VIn, KOut, VOut>(String arg0, ProcessorSupplier<KIn, VIn, KOut, VOut> arg1, params String[] arg2)

Parameters

arg0 String

String

arg1 ProcessorSupplier<KIn, VIn, KOut, VOut>

ProcessorSupplier

arg2 String[]

String

Returns

Topology

Topology

Type Parameters

KIn
VIn
KOut
VOut

AddReadOnlyStateStore<KIn, VIn>(StoreBuilder, String, Deserializer<KIn>, Deserializer<VIn>, String, String, ProcessorSupplier<KIn, VIn, Void, Void>)

public Topology AddReadOnlyStateStore<KIn, VIn>(StoreBuilder arg0, String arg1, Deserializer<KIn> arg2, Deserializer<VIn> arg3, String arg4, String arg5, ProcessorSupplier<KIn, VIn, Void, Void> arg6)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String

String

arg2 Deserializer<KIn>

Deserializer

arg3 Deserializer<VIn>

Deserializer

arg4 String

String

arg5 String

String

arg6 ProcessorSupplier<KIn, VIn, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

KIn
VIn

AddReadOnlyStateStore<KIn, VIn>(StoreBuilder, String, TimestampExtractor, Deserializer<KIn>, Deserializer<VIn>, String, String, ProcessorSupplier<KIn, VIn, Void, Void>)

public Topology AddReadOnlyStateStore<KIn, VIn>(StoreBuilder arg0, String arg1, TimestampExtractor arg2, Deserializer<KIn> arg3, Deserializer<VIn> arg4, String arg5, String arg6, ProcessorSupplier<KIn, VIn, Void, Void> arg7)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<KIn>

Deserializer

arg4 Deserializer<VIn>

Deserializer

arg5 String

String

arg6 String

String

arg7 ProcessorSupplier<KIn, VIn, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

KIn
VIn

AddSink(String, String, params String[])

public Topology AddSink(String arg0, String arg1, params String[] arg2)

Parameters

arg0 String

String

arg1 String

String

arg2 String[]

String

Returns

Topology

Topology

AddSink<K, V>(String, String, Serializer<K>, Serializer<V>, params String[])

public Topology AddSink<K, V>(String arg0, String arg1, Serializer<K> arg2, Serializer<V> arg3, params String[] arg4)

Parameters

arg0 String

String

arg1 String

String

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V>(String, TopicNameExtractor<K, V>, params String[])

public Topology AddSink<K, V>(String arg0, TopicNameExtractor<K, V> arg1, params String[] arg2)

Parameters

arg0 String

String

arg1 TopicNameExtractor<K, V>

TopicNameExtractor

arg2 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V>(String, TopicNameExtractor<K, V>, Serializer<K>, Serializer<V>, params String[])

public Topology AddSink<K, V>(String arg0, TopicNameExtractor<K, V> arg1, Serializer<K> arg2, Serializer<V> arg3, params String[] arg4)

Parameters

arg0 String

String

arg1 TopicNameExtractor<K, V>

TopicNameExtractor

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>, params String[])

public Topology AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(String arg0, String arg1, Serializer<K> arg2, Serializer<V> arg3, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV> arg4, params String[] arg5) where Arg4objectSuperK : K where Arg4objectSuperV : V

Parameters

arg0 String

String

arg1 String

String

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>

StreamPartitioner

arg5 String[]

String

Returns

Topology

Topology

Type Parameters

K
V
Arg4objectSuperK

K

Arg4objectSuperV

V

AddSink<Arg2objectSuperK, K, Arg2objectSuperV, V>(String, String, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>, params String[])

public Topology AddSink<Arg2objectSuperK, K, Arg2objectSuperV, V>(String arg0, String arg1, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV> arg2, params String[] arg3) where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 String

String

arg1 String

String

arg2 StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>

StreamPartitioner

arg3 String[]

String

Returns

Topology

Topology

Type Parameters

Arg2objectSuperK

K

K
Arg2objectSuperV

V

V

AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(String, TopicNameExtractor<K, V>, Serializer<K>, Serializer<V>, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>, params String[])

public Topology AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(String arg0, TopicNameExtractor<K, V> arg1, Serializer<K> arg2, Serializer<V> arg3, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV> arg4, params String[] arg5) where Arg4objectSuperK : K where Arg4objectSuperV : V

Parameters

arg0 String

String

arg1 TopicNameExtractor<K, V>

TopicNameExtractor

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>

StreamPartitioner

arg5 String[]

String

Returns

Topology

Topology

Type Parameters

K
V
Arg4objectSuperK

K

Arg4objectSuperV

V

AddSink<K, V, Arg2objectSuperK, Arg2objectSuperV>(String, TopicNameExtractor<K, V>, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>, params String[])

public Topology AddSink<K, V, Arg2objectSuperK, Arg2objectSuperV>(String arg0, TopicNameExtractor<K, V> arg1, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV> arg2, params String[] arg3) where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 String

String

arg1 TopicNameExtractor<K, V>

TopicNameExtractor

arg2 StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>

StreamPartitioner

arg3 String[]

String

Returns

Topology

Topology

Type Parameters

K
V
Arg2objectSuperK

K

Arg2objectSuperV

V

AddSource(String, params String[])

public Topology AddSource(String arg0, params String[] arg1)

Parameters

arg0 String

String

arg1 String[]

String

Returns

Topology

Topology

AddSource(String, Pattern)

public Topology AddSource(String arg0, Pattern arg1)

Parameters

arg0 String

String

arg1 Pattern

Pattern

Returns

Topology

Topology

AddSource(String, Deserializer<object>, Deserializer<object>, params String[])

public Topology AddSource(String arg0, Deserializer<object> arg1, Deserializer<object> arg2, params String[] arg3)

Parameters

arg0 String

String

arg1 Deserializer<object>

Deserializer

arg2 Deserializer<object>

Deserializer

arg3 String[]

String

Returns

Topology

Topology

AddSource(String, Deserializer<object>, Deserializer<object>, Pattern)

public Topology AddSource(String arg0, Deserializer<object> arg1, Deserializer<object> arg2, Pattern arg3)

Parameters

arg0 String

String

arg1 Deserializer<object>

Deserializer

arg2 Deserializer<object>

Deserializer

arg3 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, params String[])

public Topology AddSource(AutoOffsetReset arg0, String arg1, params String[] arg2)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 String[]

String

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, Pattern)

public Topology AddSource(AutoOffsetReset arg0, String arg1, Pattern arg2)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, Deserializer<object>, Deserializer<object>, params String[])

public Topology AddSource(AutoOffsetReset arg0, String arg1, Deserializer<object> arg2, Deserializer<object> arg3, params String[] arg4)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 Deserializer<object>

Deserializer

arg3 Deserializer<object>

Deserializer

arg4 String[]

String

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, Deserializer<object>, Deserializer<object>, Pattern)

public Topology AddSource(AutoOffsetReset arg0, String arg1, Deserializer<object> arg2, Deserializer<object> arg3, Pattern arg4)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 Deserializer<object>

Deserializer

arg3 Deserializer<object>

Deserializer

arg4 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, TimestampExtractor, Deserializer<object>, Deserializer<object>, params String[])

public Topology AddSource(AutoOffsetReset arg0, String arg1, TimestampExtractor arg2, Deserializer<object> arg3, Deserializer<object> arg4, params String[] arg5)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<object>

Deserializer

arg4 Deserializer<object>

Deserializer

arg5 String[]

String

Returns

Topology

Topology

AddSource(AutoOffsetReset, String, TimestampExtractor, Deserializer<object>, Deserializer<object>, Pattern)

public Topology AddSource(AutoOffsetReset arg0, String arg1, TimestampExtractor arg2, Deserializer<object> arg3, Deserializer<object> arg4, Pattern arg5)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<object>

Deserializer

arg4 Deserializer<object>

Deserializer

arg5 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, TimestampExtractor, String, params String[])

public Topology AddSource(AutoOffsetReset arg0, TimestampExtractor arg1, String arg2, params String[] arg3)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 TimestampExtractor

TimestampExtractor

arg2 String

String

arg3 String[]

String

Returns

Topology

Topology

AddSource(AutoOffsetReset, TimestampExtractor, String, Pattern)

public Topology AddSource(AutoOffsetReset arg0, TimestampExtractor arg1, String arg2, Pattern arg3)

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 TimestampExtractor

TimestampExtractor

arg2 String

String

arg3 Pattern

Pattern

Returns

Topology

Topology

AddSource(TimestampExtractor, String, params String[])

public Topology AddSource(TimestampExtractor arg0, String arg1, params String[] arg2)

Parameters

arg0 TimestampExtractor

TimestampExtractor

arg1 String

String

arg2 String[]

String

Returns

Topology

Topology

AddSource(TimestampExtractor, String, Pattern)

public Topology AddSource(TimestampExtractor arg0, String arg1, Pattern arg2)

Parameters

arg0 TimestampExtractor

TimestampExtractor

arg1 String

String

arg2 Pattern

Pattern

Returns

Topology

Topology

AddStateStore(StoreBuilder, params String[])

public Topology AddStateStore(StoreBuilder arg0, params String[] arg1)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String[]

String

Returns

Topology

Topology

ConnectProcessorAndStateStores(String, params String[])

public Topology ConnectProcessorAndStateStores(String arg0, params String[] arg1)

Parameters

arg0 String

String

arg1 String[]

String

Returns

Topology

Topology

Describe()

public TopologyDescription Describe()

Returns

TopologyDescription

TopologyDescription