Class KStream<K, V>

Namespace

Org.Apache.Kafka.Streams.Scala.Kstream

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/kstream/KStream.html

public class KStream<K, V> : JVMBridgeBase<KStream<K, V>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Type Parameters

K

V

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<KStream<K, V>>

KStream<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

KStream(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 KStream(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

KStream(KStream<K, V>)

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

public KStream(KStream<K, V> inner)

Parameters

inner KStream<K, V>

KStream

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

CreatePoolableInstance(KStream<K, V>)

HPA initializer for KStream(Org.Apache.Kafka.Streams.Kstream.KStream%3CK, V%3E inner)

public static KStream<K, V> CreatePoolableInstance(KStream<K, V> inner)

Parameters

inner KStream<K, V>

Returns

KStream<K, V>

GroupByKey(Grouped<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#groupByKey(org.apache.kafka.streams.kstream.Grouped)

public KGroupedStream<K, V> GroupByKey(Grouped<K, V> grouped)

Parameters

grouped Grouped<K, V>

Grouped

Returns

KGroupedStream<K, V>

KGroupedStream

Inner()

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

public KStream<K, V> Inner()

Returns

KStream<K, V>

KStream

Merge(KStream<K, V>)

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

public KStream<K, V> Merge(KStream<K, V> stream)

Parameters

stream KStream<K, V>

KStream

Returns

KStream<K, V>

KStream

Merge(KStream<K, V>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#merge(org.apache.kafka.streams.scala.kstream.KStream,org.apache.kafka.streams.kstream.Named)

public KStream<K, V> Merge(KStream<K, V> stream, Named named)

Parameters

stream KStream<K, V>

KStream

named Named

Named

Returns

KStream<K, V>

KStream

Print(Printed<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#print(org.apache.kafka.streams.kstream.Printed)

public void Print(Printed<K, V> printed)

Parameters

printed Printed<K, V>

Printed

Repartition(Repartitioned<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#repartition(org.apache.kafka.streams.kstream.Repartitioned)

public KStream<K, V> Repartition(Repartitioned<K, V> repartitioned)

Parameters

repartitioned Repartitioned<K, V>

Repartitioned

Returns

KStream<K, V>

KStream

Split()

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

public BranchedKStream<K, V> Split()

Returns

BranchedKStream<K, V>

BranchedKStream

Split(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#split(org.apache.kafka.streams.kstream.Named)

public BranchedKStream<K, V> Split(Named named)

Parameters

named Named

Named

Returns

BranchedKStream<K, V>

BranchedKStream

To(String, Produced<K, V>)

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

public void To(String topic, Produced<K, V> produced)

Parameters

topic String

String

produced Produced<K, V>

Produced

To(TopicNameExtractor<K, V>, Produced<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#to(org.apache.kafka.streams.processor.TopicNameExtractor,org.apache.kafka.streams.kstream.Produced)

public void To(TopicNameExtractor<K, V> extractor, Produced<K, V> produced)

Parameters

extractor TopicNameExtractor<K, V>

TopicNameExtractor

produced Produced<K, V>

Produced

ToTable()

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

public KTable<K, V> ToTable()

Returns

KTable<K, V>

KTable

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V> ToTable(Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)

Parameters

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

Materialized

Returns

KTable<K, V>

KTable

ToTable(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Named)

public KTable<K, V> ToTable(Named named)

Parameters

named Named

Named

Returns

KTable<K, V>

KTable

ToTable(Named, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.2.1/org/apache/kafka/streams/scala/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Named,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V> ToTable(Named named, Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)

Parameters

named Named

Named

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

Materialized

Returns

KTable<K, V>

KTable

Operators

implicit operator KStream(KStream<K, V>)

Converter from KStream<K, V> to KStream

public static implicit operator KStream(KStream<K, V> t)

Parameters

t KStream<K, V>

Returns

KStream