Class ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Namespace

MASES.KNet.Streams.Processor.Api

Assembly

MASES.KNet.dll

KNet implementation of ProcessorContext<KForward, VForward>

public class ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Type Parameters

KForward

VForward

TJVMKForward

The JVM type of KForward

TJVMVForward

The JVM type of VForward

Inheritance

object

ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

AppConfigs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#appConfigs--

public Map<String, object> AppConfigs { get; }

Property Value

Map<String, object>

Map

ApplicationId

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#applicationId--

public string ApplicationId { get; }

Property Value

string

string

CurrentStreamDateTime

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#currentStreamTimeMs--

public DateTime CurrentStreamDateTime { get; }

Property Value

DateTime

DateTime

CurrentStreamTimeMs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#currentStreamTimeMs--

public long CurrentStreamTimeMs { get; }

Property Value

long

long

CurrentSystemDateTime

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#currentSystemTimeMs--

public DateTime CurrentSystemDateTime { get; }

Property Value

DateTime

DateTime

CurrentSystemTimeMs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#currentSystemTimeMs--

public long CurrentSystemTimeMs { get; }

Property Value

long

long

KeySerde

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#keySerde--

public Serde<object> KeySerde { get; }

Property Value

Serde<object>

Serde

Metrics

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#metrics--

public StreamsMetrics Metrics { get; }

Property Value

StreamsMetrics

StreamsMetrics

RecordMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#recordMetadata--

public RecordMetadata? RecordMetadata { get; }

Property Value

RecordMetadata

Optional

StateDir

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#stateDir--

public File StateDir { get; }

Property Value

File

File

TaskId

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#taskId--

public TaskId TaskId { get; }

Property Value

TaskId

TaskId

ValueSerde

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#valueSerde--

public Serde<object> ValueSerde { get; }

Property Value

Serde<object>

Serde

Methods

AppConfigsWithPrefix(string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#appConfigsWithPrefix-java.lang.String-

public Map<String, object> AppConfigsWithPrefix(string arg0)

Parameters

arg0 string

string

Returns

Map<String, object>

Map

Commit()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#commit--

public void Commit()

Forward<K, V, TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessorContext.html#forward-org.apache.kafka.streams.processor.api.Record-

public void Forward<K, V, TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV> arg0) where K : KForward where V : VForward where TJVMK : TJVMKForward where TJVMV : TJVMVForward

Parameters

arg0 Record<K, V, TJVMK, TJVMV>

Record

Type Parameters

K

KForward

V

VForward

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Forward<K, V, TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV>, string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessorContext.html#forward-org.apache.kafka.streams.processor.api.Record-java.lang.String-

public void Forward<K, V, TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV> arg0, string arg1) where K : KForward where V : VForward where TJVMK : TJVMKForward where TJVMV : TJVMVForward

Parameters

arg0 Record<K, V, TJVMK, TJVMV>

Record

arg1 string

string

Type Parameters

K

KForward

V

VForward

TJVMK

The JVM type of K

TJVMV

The JVM type of V

GetStateStore<S>(string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#getStateStore-java.lang.String-

public S GetStateStore<S>(string arg0) where S : IStateStore, new()

Parameters

arg0 string

string

Returns

S

S

Type Parameters

S

IStateStore

Schedule(Duration, PunctuationType, Punctuator)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#schedule-java.time.Duration-org.apache.kafka.streams.processor.PunctuationType-org.apache.kafka.streams.processor.Punctuator-

public Cancellable Schedule(Duration arg0, PunctuationType arg1, Punctuator arg2)

Parameters

arg0 Duration

Duration

arg1 PunctuationType

PunctuationType

arg2 Punctuator

Punctuator

Returns

Cancellable

Cancellable

Operators

implicit operator ProcessorContext<TJVMKForward, TJVMVForward>(ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>)

Converter from ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward> to ProcessorContext<KForward, VForward>

public static implicit operator ProcessorContext<TJVMKForward, TJVMVForward>(ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward> t)

Parameters

t ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Returns

ProcessorContext<TJVMKForward, TJVMVForward>