Class KStream

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 : JVMBridgeBase<KStream>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<KStream>

KStream

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)

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 inner)

Parameters

inner KStream

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)

HPA initializer for KStream(Org.Apache.Kafka.Streams.Kstream.KStream inner)

public static KStream CreatePoolableInstance(KStream inner)

Parameters

inner KStream

Returns

KStream

GroupByKey(Grouped)

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 GroupByKey(Grouped grouped)

Parameters

grouped Grouped

Grouped

Returns

KGroupedStream

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

Returns

KStream

KStream

Merge(KStream)

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 Merge(KStream stream)

Parameters

stream KStream

KStream

Returns

KStream

KStream

Merge(KStream, 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 Merge(KStream stream, Named named)

Parameters

stream KStream

KStream

named Named

Named

Returns

KStream

KStream

Print(Printed)

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 printed)

Parameters

printed Printed

Printed

Repartition(Repartitioned)

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 Repartition(Repartitioned repartitioned)

Parameters

repartitioned Repartitioned

Repartitioned

Returns

KStream

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

Returns

BranchedKStream

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 Split(Named named)

Parameters

named Named

Named

Returns

BranchedKStream

BranchedKStream

To(String, Produced)

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 produced)

Parameters

topic String

String

produced Produced

Produced

To(TopicNameExtractor, Produced)

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 extractor, Produced produced)

Parameters

extractor TopicNameExtractor

TopicNameExtractor

produced Produced

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

Returns

KTable

KTable

ToTable(Materialized)

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 ToTable(Materialized materialized)

Parameters

materialized Materialized

Materialized

Returns

KTable

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 ToTable(Named named)

Parameters

named Named

Named

Returns

KTable

KTable

ToTable(Named, Materialized)

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 ToTable(Named named, Materialized materialized)

Parameters

named Named

Named

materialized Materialized

Materialized

Returns

KTable

KTable