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> : IKNetInnerReference<ProcessorContext<TJVMKForward, TJVMVForward>>, IDisposable

Type Parameters

KForward

VForward

TJVMKForward

The JVM type of KForward

TJVMVForward

The JVM type of VForward

Inheritance

object

ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Implements

IKNetInnerReference<ProcessorContext<TJVMKForward, TJVMVForward>>

IDisposable

Properties

AppConfigs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.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/4.2.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/4.2.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/4.2.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/4.2.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/4.2.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#currentSystemTimeMs()

public long CurrentSystemTimeMs { get; }

Property Value

long

long

InnerReference

The underlying inner reference used from KNet object instance

public ProcessorContext<TJVMKForward, TJVMVForward> InnerReference { get; }

Property Value

ProcessorContext<TJVMKForward, TJVMVForward>

KeySerde

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.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/4.2.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/4.2.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/4.2.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/4.2.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/4.2.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/4.2.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

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Commit()

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

public void Commit()

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)

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.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/4.2.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/4.2.1/org/apache/kafka/streams/processor/api/ProcessingContext.html#getStateStore(java.lang.String)

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

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/4.2.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>