Table of Contents

Class StreamsBuilder

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

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

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

Constructors

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(StreamsBuilder)

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

public StreamsBuilder(StreamsBuilder inner)

Parameters

inner StreamsBuilder

StreamsBuilder

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/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<StoreBuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore, K, V>(StoreBuilder<StoreBuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore> storeBuilder, String topic, Consumed<K, V> consumed, ProcessorSupplier<K, V, Void, Void> stateUpdateSupplier) where StoreBuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore : StateStore

Parameters

storeBuilder StoreBuilder<StoreBuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore>

StoreBuilder

topic String

String

consumed Consumed<K, V>

Consumed

stateUpdateSupplier ProcessorSupplier<K, V, Void, Void>

ProcessorSupplier

Returns

StreamsBuilder

StreamsBuilder

Type Parameters

StoreBuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore

StateStore

K
V

AddStateStore<BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore>(StoreBuilder<BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore>)

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

public StreamsBuilder AddStateStore<BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore>(StoreBuilder<BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore> builder) where BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore : StateStore

Parameters

builder StoreBuilder<BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore>

StoreBuilder

Returns

StreamsBuilder

StreamsBuilder

Type Parameters

BuilderExtendsOrg_Apache_Kafka_Streams_Processor_StateStore

StateStore

Build()

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

public Topology Build()

Returns

Topology

Topology

Build(Properties)

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

public Topology Build(Properties props)

Parameters

props Properties

Properties

Returns

Topology

Topology

CreatePoolableInstance(StreamsBuilder)

HPA initializer for StreamsBuilder(Org.Apache.Kafka.Streams.StreamsBuilder inner)

public static StreamsBuilder CreatePoolableInstance(StreamsBuilder inner)

Parameters

inner StreamsBuilder

Returns

StreamsBuilder

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

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

public GlobalKTable<K, V> GlobalTable<K, V>(String topic, Consumed<K, V> consumed)

Parameters

topic String

String

consumed Consumed<K, V>

Consumed

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

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

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

public GlobalKTable<K, V> GlobalTable<K, V>(String topic, Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized, Consumed<K, V> consumed)

Parameters

topic String

String

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

Materialized

consumed Consumed<K, V>

Consumed

Returns

GlobalKTable<K, V>

GlobalKTable

Type Parameters

K
V

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

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

public KStream<K, V> Stream<K, V>(String topic, Consumed<K, V> consumed)

Parameters

topic String

String

consumed Consumed<K, V>

Consumed

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-scala_2.13/4.2.1/org/apache/kafka/streams/scala/StreamsBuilder.html#stream(java.util.regex.Pattern,org.apache.kafka.streams.kstream.Consumed)

public KStream<K, V> Stream<K, V>(Pattern topicPattern, Consumed<K, V> consumed)

Parameters

topicPattern Pattern

Pattern

consumed Consumed<K, V>

Consumed

Returns

KStream<K, V>

KStream

Type Parameters

K
V

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

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

public KTable<K, V> Table<K, V>(String topic, Consumed<K, V> consumed)

Parameters

topic String

String

consumed Consumed<K, V>

Consumed

Returns

KTable<K, V>

KTable

Type Parameters

K
V

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

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

public KTable<K, V> Table<K, V>(String topic, Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized, Consumed<K, V> consumed)

Parameters

topic String

String

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

Materialized

consumed Consumed<K, V>

Consumed

Returns

KTable<K, V>

KTable

Type Parameters

K
V
Edit this page