Table of Contents

Class Topology

Namespace
Org.Apache.Kafka.Streams
Assembly
MASES.KNet.dll
public class Topology : JVMBridgeBase<Topology>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, 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(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

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

Parameters

initializer IJVMBridgeBaseInitializer

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<S, K, V>(StoreBuilder<S>, String, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V, Void, Void>)

public Topology AddGlobalStore<S, K, V>(StoreBuilder<S> arg0, String arg1, Deserializer<K> arg2, Deserializer<V> arg3, String arg4, String arg5, ProcessorSupplier<K, V, Void, Void> arg6) where S : IStateStore, new()

Parameters

arg0 StoreBuilder<S>

StoreBuilder

arg1 String

String

arg2 Deserializer<K>

Deserializer

arg3 Deserializer<V>

Deserializer

arg4 String

String

arg5 String

String

arg6 ProcessorSupplier<K, V, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

S

IStateStore

K
V

AddGlobalStore<S, K, V>(StoreBuilder<S>, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V, Void, Void>)

public Topology AddGlobalStore<S, K, V>(StoreBuilder<S> arg0, String arg1, TimestampExtractor arg2, Deserializer<K> arg3, Deserializer<V> arg4, String arg5, String arg6, ProcessorSupplier<K, V, Void, Void> arg7) where S : IStateStore, new()

Parameters

arg0 StoreBuilder<S>

StoreBuilder

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<K>

Deserializer

arg4 Deserializer<V>

Deserializer

arg5 String

String

arg6 String

String

arg7 ProcessorSupplier<K, V, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

S

IStateStore

K
V

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<S, K, V>(StoreBuilder<S>, String, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V, Void, Void>)

public Topology AddReadOnlyStateStore<S, K, V>(StoreBuilder<S> arg0, String arg1, Deserializer<K> arg2, Deserializer<V> arg3, String arg4, String arg5, ProcessorSupplier<K, V, Void, Void> arg6) where S : IStateStore, new()

Parameters

arg0 StoreBuilder<S>

StoreBuilder

arg1 String

String

arg2 Deserializer<K>

Deserializer

arg3 Deserializer<V>

Deserializer

arg4 String

String

arg5 String

String

arg6 ProcessorSupplier<K, V, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

S

IStateStore

K
V

AddReadOnlyStateStore<S, K, V>(StoreBuilder<S>, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V, Void, Void>)

public Topology AddReadOnlyStateStore<S, K, V>(StoreBuilder<S> arg0, String arg1, TimestampExtractor arg2, Deserializer<K> arg3, Deserializer<V> arg4, String arg5, String arg6, ProcessorSupplier<K, V, Void, Void> arg7) where S : IStateStore, new()

Parameters

arg0 StoreBuilder<S>

StoreBuilder

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<K>

Deserializer

arg4 Deserializer<V>

Deserializer

arg5 String

String

arg6 String

String

arg7 ProcessorSupplier<K, V, Void, Void>

ProcessorSupplier

Returns

Topology

Topology

Type Parameters

S

IStateStore

K
V

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, 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<Arg1objectSuperK, K, Arg1objectSuperV, V>(String, TopicNameExtractor<Arg1objectSuperK, Arg1objectSuperV>, params String[])

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

Parameters

arg0 String

String

arg1 TopicNameExtractor<Arg1objectSuperK, Arg1objectSuperV>

TopicNameExtractor

arg2 String[]

String

Returns

Topology

Topology

Type Parameters

Arg1objectSuperK

K

K
Arg1objectSuperV

V

V

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

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

Parameters

arg0 String

String

arg1 TopicNameExtractor<Arg1objectSuperK, Arg1objectSuperV>

TopicNameExtractor

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 String[]

String

Returns

Topology

Topology

Type Parameters

Arg1objectSuperK

K

K
Arg1objectSuperV

V

V

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

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

Parameters

arg0 String

String

arg1 TopicNameExtractor<Arg1objectSuperK, Arg1objectSuperV>

TopicNameExtractor

arg2 Serializer<K>

Serializer

arg3 Serializer<V>

Serializer

arg4 StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>

StreamPartitioner

arg5 String[]

String

Returns

Topology

Topology

Type Parameters

Arg1objectSuperK

K

K
Arg1objectSuperV

V

V
Arg4objectSuperK

K

Arg4objectSuperV

V

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

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

Parameters

arg0 String

String

arg1 TopicNameExtractor<Arg1objectSuperK, Arg1objectSuperV>

TopicNameExtractor

arg2 StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>

StreamPartitioner

arg3 String[]

String

Returns

Topology

Topology

Type Parameters

Arg1objectSuperK

K

K
Arg1objectSuperV

V

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(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, 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

AddSource<K, V>(String, Deserializer<K>, Deserializer<V>, params String[])

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

Parameters

arg0 String

String

arg1 Deserializer<K>

Deserializer

arg2 Deserializer<V>

Deserializer

arg3 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSource<K, V>(String, Deserializer<K>, Deserializer<V>, Pattern)

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

Parameters

arg0 String

String

arg1 Deserializer<K>

Deserializer

arg2 Deserializer<V>

Deserializer

arg3 Pattern

Pattern

Returns

Topology

Topology

Type Parameters

K
V

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

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

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 Deserializer<K>

Deserializer

arg3 Deserializer<V>

Deserializer

arg4 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSource<K, V>(AutoOffsetReset, String, Deserializer<K>, Deserializer<V>, Pattern)

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

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 Deserializer<K>

Deserializer

arg3 Deserializer<V>

Deserializer

arg4 Pattern

Pattern

Returns

Topology

Topology

Type Parameters

K
V

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

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

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<K>

Deserializer

arg4 Deserializer<V>

Deserializer

arg5 String[]

String

Returns

Topology

Topology

Type Parameters

K
V

AddSource<K, V>(AutoOffsetReset, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, Pattern)

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

Parameters

arg0 AutoOffsetReset

AutoOffsetReset

arg1 String

String

arg2 TimestampExtractor

TimestampExtractor

arg3 Deserializer<K>

Deserializer

arg4 Deserializer<V>

Deserializer

arg5 Pattern

Pattern

Returns

Topology

Topology

Type Parameters

K
V

AddStateStore<S>(StoreBuilder<S>, params String[])

public Topology AddStateStore<S>(StoreBuilder<S> arg0, params String[] arg1) where S : IStateStore, new()

Parameters

arg0 StoreBuilder<S>

StoreBuilder

arg1 String[]

String

Returns

Topology

Topology

Type Parameters

S

IStateStore

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