Class Consumed<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of Consumed<K, V>

public class Consumed<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

Consumed<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

As(string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#as-java.lang.String-

public static Consumed<K, V, TJVMK, TJVMV> As(string arg0)

Parameters

arg0 string

string

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#with-org.apache.kafka.common.serialization.Serde-org.apache.kafka.common.serialization.Serde-

public static Consumed<K, V, TJVMK, TJVMV> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>, TimestampExtractor<K, V, TJVMK, TJVMV>, AutoOffsetReset)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#with-org.apache.kafka.common.serialization.Serde-org.apache.kafka.common.serialization.Serde-org.apache.kafka.streams.processor.TimestampExtractor-org.apache.kafka.streams.Topology.AutoOffsetReset-

public static Consumed<K, V, TJVMK, TJVMV> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1, TimestampExtractor<K, V, TJVMK, TJVMV> arg2, Topology.AutoOffsetReset arg3)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

arg2 TimestampExtractor<K, V, TJVMK, TJVMV>

TimestampExtractor<K, V, TJVMK, TJVMV>

arg3 Topology.AutoOffsetReset

Topology.AutoOffsetReset

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

With(TimestampExtractor<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#with-org.apache.kafka.streams.processor.TimestampExtractor-

public static Consumed<K, V, TJVMK, TJVMV> With(TimestampExtractor<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 TimestampExtractor<K, V, TJVMK, TJVMV>

TimestampExtractor<K, V, TJVMK, TJVMV>

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

With(AutoOffsetReset)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#with-org.apache.kafka.streams.Topology.AutoOffsetReset-

public static Consumed<K, V, TJVMK, TJVMV> With(Topology.AutoOffsetReset arg0)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

WithKeySerde(ISerDes<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#withKeySerde-org.apache.kafka.common.serialization.Serde-

public Consumed<K, V, TJVMK, TJVMV> WithKeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

WithOffsetResetPolicy(AutoOffsetReset)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#withOffsetResetPolicy-org.apache.kafka.streams.Topology.AutoOffsetReset-

public Consumed<K, V, TJVMK, TJVMV> WithOffsetResetPolicy(Topology.AutoOffsetReset arg0)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

WithTimestampExtractor(TimestampExtractor<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#withTimestampExtractor-org.apache.kafka.streams.processor.TimestampExtractor-

public Consumed<K, V, TJVMK, TJVMV> WithTimestampExtractor(TimestampExtractor<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 TimestampExtractor<K, V, TJVMK, TJVMV>

TimestampExtractor<K, V, TJVMK, TJVMV>

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

WithValueSerde(ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Consumed.html#withValueSerde-org.apache.kafka.common.serialization.Serde-

public Consumed<K, V, TJVMK, TJVMV> WithValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Consumed<K, V, TJVMK, TJVMV>

Consumed<K, V, TJVMK, TJVMV>

Operators

implicit operator Consumed<TJVMK, TJVMV>(Consumed<K, V, TJVMK, TJVMV>)

Converter from Consumed<K, V, TJVMK, TJVMV> to Consumed<K, V>

public static implicit operator Consumed<TJVMK, TJVMV>(Consumed<K, V, TJVMK, TJVMV> t)

Parameters

t Consumed<K, V, TJVMK, TJVMV>

Returns

Consumed<TJVMK, TJVMV>