Table of Contents

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/3.9.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(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/3.5.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/3.5.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/3.5.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>
Edit this page