Interface IProcessor<KIn, VIn, KOut, VOut>

Namespace

Org.Apache.Kafka.Streams.Processor.Api

Assembly

MASES.KNet.dll

.NET interface for org.mases.knet.generated.org.apache.kafka.streams.processor.api.Processor implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/Processor.html

public interface IProcessor<KIn, VIn, KOut, VOut> : IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

KIn

VIn

KOut

VOut

Inherited Members

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

Methods

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/Processor.html#close()

void Close()

Init(ProcessorContext<KOut, VOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/Processor.html#init(org.apache.kafka.streams.processor.api.ProcessorContext)

void Init(ProcessorContext<KOut, VOut> context)

Parameters

context ProcessorContext<KOut, VOut>

Process(Record<KIn, VIn>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/Processor.html#process(org.apache.kafka.streams.processor.api.Record)

void Process(Record<KIn, VIn> record)

Parameters

record Record<KIn, VIn>