Table of Contents

Class StreamsBuilder

Namespace
Org.Apache.Kafka.Streams
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html

public class StreamsBuilder : JVMBridgeBase<StreamsBuilder>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
Inheritance
StreamsBuilder
Implements

Constructors

StreamsBuilder()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#%3Cinit%3E()

public StreamsBuilder()

StreamsBuilder(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

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

Parameters

initializer IJVMBridgeBaseInitializer

StreamsBuilder(TopologyConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#%3Cinit%3E(org.apache.kafka.streams.TopologyConfig)

public StreamsBuilder(TopologyConfig arg0)

Parameters

arg0 TopologyConfig

TopologyConfig

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 java.lang.AutoCloseable

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, Consumed<KIn, VIn>, ProcessorSupplier<KIn, VIn, Void, Void>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#addGlobalStore(org.apache.kafka.streams.state.StoreBuilder,java.lang.String,org.apache.kafka.streams.kstream.Consumed,org.apache.kafka.streams.processor.api.ProcessorSupplier)

public StreamsBuilder AddGlobalStore<KIn, VIn>(StoreBuilder arg0, String arg1, Consumed<KIn, VIn> arg2, ProcessorSupplier<KIn, VIn, Void, Void> arg3)

Parameters

arg0 StoreBuilder

StoreBuilder

arg1 String

String

arg2 Consumed<KIn, VIn>

Consumed

arg3 ProcessorSupplier<KIn, VIn, Void, Void>

ProcessorSupplier

Returns

StreamsBuilder

StreamsBuilder

Type Parameters

KIn
VIn

AddStateStore(StoreBuilder)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#addStateStore(org.apache.kafka.streams.state.StoreBuilder)

public StreamsBuilder AddStateStore(StoreBuilder arg0)

Parameters

arg0 StoreBuilder

StoreBuilder

Returns

StreamsBuilder

StreamsBuilder

Build()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#build()

public Topology Build()

Returns

Topology

Topology

Build(Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#build(java.util.Properties)

public Topology Build(Properties arg0)

Parameters

arg0 Properties

Properties

Returns

Topology

Topology

CreatePoolableInstance()

HPA initializer for StreamsBuilder()

public static StreamsBuilder CreatePoolableInstance()

Returns

StreamsBuilder

CreatePoolableInstance(TopologyConfig)

HPA initializer for StreamsBuilder(Org.Apache.Kafka.Streams.TopologyConfig arg0)

public static StreamsBuilder CreatePoolableInstance(TopologyConfig arg0)

Parameters

arg0 TopologyConfig

Returns

StreamsBuilder

GlobalTable<K, V>(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#globalTable(java.lang.String)

public GlobalKTable<K, V> GlobalTable<K, V>(String arg0)

Parameters

arg0 String

String

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

GlobalTable<K, V>(String, Consumed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#globalTable(java.lang.String,org.apache.kafka.streams.kstream.Consumed)

public GlobalKTable<K, V> GlobalTable<K, V>(String arg0, Consumed<K, V> arg1)

Parameters

arg0 String

String

arg1 Consumed<K, V>

Consumed

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

GlobalTable<K, V>(String, Consumed<K, V>, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#globalTable(java.lang.String,org.apache.kafka.streams.kstream.Consumed,org.apache.kafka.streams.kstream.Materialized)

public GlobalKTable<K, V> GlobalTable<K, V>(String arg0, Consumed<K, V> arg1, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg2)

Parameters

arg0 String

String

arg1 Consumed<K, V>

Consumed

arg2 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

GlobalTable<K, V>(String, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#globalTable(java.lang.String,org.apache.kafka.streams.kstream.Materialized)

public GlobalKTable<K, V> GlobalTable<K, V>(String arg0, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg1)

Parameters

arg0 String

String

arg1 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

Stream<K, V>(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.lang.String)

public KStream<K, V> Stream<K, V>(String arg0)

Parameters

arg0 String

String

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Stream<K, V>(String, Consumed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.lang.String,org.apache.kafka.streams.kstream.Consumed)

public KStream<K, V> Stream<K, V>(String arg0, Consumed<K, V> arg1)

Parameters

arg0 String

String

arg1 Consumed<K, V>

Consumed

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Stream<K, V>(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.util.Collection)

public KStream<K, V> Stream<K, V>(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Stream<K, V>(Collection<String>, Consumed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.util.Collection,org.apache.kafka.streams.kstream.Consumed)

public KStream<K, V> Stream<K, V>(Collection<String> arg0, Consumed<K, V> arg1)

Parameters

arg0 Collection<String>

Collection

arg1 Consumed<K, V>

Consumed

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Stream<K, V>(Pattern)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.util.regex.Pattern)

public KStream<K, V> Stream<K, V>(Pattern arg0)

Parameters

arg0 Pattern

Pattern

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Stream<K, V>(Pattern, Consumed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#stream(java.util.regex.Pattern,org.apache.kafka.streams.kstream.Consumed)

public KStream<K, V> Stream<K, V>(Pattern arg0, Consumed<K, V> arg1)

Parameters

arg0 Pattern

Pattern

arg1 Consumed<K, V>

Consumed

Returns

KStream<K, V>

KStream

Type Parameters

K
V

Table<K, V>(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#table(java.lang.String)

public KTable<K, V> Table<K, V>(String arg0)

Parameters

arg0 String

String

Returns

KTable<K, V>

KTable

Type Parameters

K
V

Table<K, V>(String, Consumed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#table(java.lang.String,org.apache.kafka.streams.kstream.Consumed)

public KTable<K, V> Table<K, V>(String arg0, Consumed<K, V> arg1)

Parameters

arg0 String

String

arg1 Consumed<K, V>

Consumed

Returns

KTable<K, V>

KTable

Type Parameters

K
V

Table<K, V>(String, Consumed<K, V>, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#table(java.lang.String,org.apache.kafka.streams.kstream.Consumed,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V> Table<K, V>(String arg0, Consumed<K, V> arg1, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg2)

Parameters

arg0 String

String

arg1 Consumed<K, V>

Consumed

arg2 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

KTable<K, V>

KTable

Type Parameters

K
V

Table<K, V>(String, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/StreamsBuilder.html#table(java.lang.String,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V> Table<K, V>(String arg0, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg1)

Parameters

arg0 String

String

arg1 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

KTable<K, V>

KTable

Type Parameters

K
V
Edit this page