Class StreamsBuilder
KNet extension of StreamsBuilder
public class StreamsBuilder : IKNetInnerReference<StreamsBuilder>, IGenericSerDesFactoryApplier, IDisposable- Inheritance
-
StreamsBuilder
- Implements
Constructors
StreamsBuilder(StreamsConfigBuilder)
public StreamsBuilder(StreamsConfigBuilder factory)Parameters
factoryStreamsConfigBuilderStreamsConfigBuilder used as reference of IGenericSerDesFactory
StreamsBuilder(TopologyConfig)
public StreamsBuilder(TopologyConfig arg0)Parameters
Properties
InnerReference
The underlying inner reference used from KNet object instance
public StreamsBuilder InnerReference { get; }Property Value
OverrideProperties
If set, this Func<T, TResult> will be called from PrepareProperties(StreamsConfigBuilder)
public static Func<StreamsConfigBuilder, Properties> OverrideProperties { get; set; }Property Value
Methods
AddStateStore(StoreBuilder)
public StreamsBuilder AddStateStore(StoreBuilder arg0)Parameters
arg0StoreBuilder
Returns
Build()
public Topology Build()Returns
Build(Properties)
public Topology Build(Properties arg0)Parameters
arg0Properties
Returns
CheckDisposed()
Test if this instance was disposed
protected void CheckDisposed()Exceptions
- ObjectDisposedException
When this instance was disposed
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public void Dispose()Dispose(bool)
Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose
protected virtual void Dispose(bool disposing)Parameters
disposingboolThe disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)
GlobalTable<K, V, TJVMK, TJVMV>(string)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)Parameters
arg0stringarg1Consumed<K, V, TJVMK, TJVMV>arg2Materialized<K, V, TJVMK, TJVMV>
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Materialized<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Materialized<K, V, TJVMK, TJVMV> arg1)Parameters
arg0stringarg1Materialized<K, V, TJVMK, TJVMV>
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
PrepareProperties(StreamsConfigBuilder)
Override this method to check and modify the Properties returned to underlying KafkaStreams
protected virtual Properties PrepareProperties(StreamsConfigBuilder builder)Parameters
builderStreamsConfigBuilderStreamsConfigBuilder to use to return Properties
Returns
- Properties
Properties used from underlying KafkaStreams
Stream<K, V, TJVMK, TJVMV>(Pattern)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(Pattern arg0)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(Pattern, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(Pattern arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(IEnumerable<string>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(IEnumerable<string> arg0)Parameters
arg0IEnumerable<string>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(IEnumerable<string>, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(IEnumerable<string> arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
arg0IEnumerable<string>arg1Consumed<K, V, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(string)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)Parameters
arg0stringarg1Consumed<K, V, TJVMK, TJVMV>arg2Materialized<K, V, TJVMK, TJVMV>
Returns
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Materialized<K, V, TJVMK, TJVMV> arg1)Parameters
arg0stringarg1Materialized<K, V, TJVMK, TJVMV>
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V