Interface IFixedKeyProcessor<KIn, VIn, 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.FixedKeyProcessor implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/FixedKeyProcessor.html

public interface IFixedKeyProcessor<KIn, VIn, VOut> : IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

KIn

VIn

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/FixedKeyProcessor.html#close()

void Close()

Init(FixedKeyProcessorContext<KIn, VOut>)

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

void Init(FixedKeyProcessorContext<KIn, VOut> context)

Parameters

context FixedKeyProcessorContext<KIn, VOut>

Process(FixedKeyRecord<KIn, VIn>)

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

void Process(FixedKeyRecord<KIn, VIn> record)

Parameters

record FixedKeyRecord<KIn, VIn>