Class Produced<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of Produced<K, V>

public class Produced<K, V, TJVMK, TJVMV> : IKNetInnerReference<Produced<TJVMK, TJVMV>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

Produced<K, V, TJVMK, TJVMV>

Implements

IKNetInnerReference<Produced<TJVMK, TJVMV>>

IGenericSerDesFactoryApplier

IDisposable

Derived

Produced<K, V>

Properties

InnerReference

The underlying inner reference used from KNet object instance

public Produced<TJVMK, TJVMV> InnerReference { get; }

Property Value

Produced<TJVMK, TJVMV>

Methods

As(string)

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

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

Parameters

arg0 string

string

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

The disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)

KeySerde(ISerDes<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#keySerde(org.apache.kafka.common.serialization.Serde)

public static Produced<K, V, TJVMK, TJVMV> KeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

StreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#streamPartitioner(org.apache.kafka.streams.processor.StreamPartitioner)

public static Produced<K, V, TJVMK, TJVMV> StreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 StreamPartitioner<K, V, TJVMK, TJVMV>

StreamPartitioner<K, V>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

ValueSerde(ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#valueSerde(org.apache.kafka.common.serialization.Serde)

public static Produced<K, V, TJVMK, TJVMV> ValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#with(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Produced<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

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#with(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde,org.apache.kafka.streams.processor.StreamPartitioner)

public static Produced<K, V, TJVMK, TJVMV> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1, StreamPartitioner<K, V, TJVMK, TJVMV> arg2)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

arg2 StreamPartitioner<K, V, TJVMK, TJVMV>

StreamPartitioner<K, V>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

WithKeySerde(ISerDes<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#withKeySerde(org.apache.kafka.common.serialization.Serde)

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

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

WithStreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#withStreamPartitioner(org.apache.kafka.streams.processor.StreamPartitioner)

public Produced<K, V, TJVMK, TJVMV> WithStreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 StreamPartitioner<K, V, TJVMK, TJVMV>

StreamPartitioner<K, V, TJVMK, TJVMV>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

WithValueSerde(ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Produced.html#withValueSerde(org.apache.kafka.common.serialization.Serde)

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

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

Operators

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

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

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

Parameters

t Produced<K, V, TJVMK, TJVMV>

Returns

Produced<TJVMK, TJVMV>