Table of Contents

Namespace Org.Apache.Kafka.Streams.Processor.Api

Classes

ContextualFixedKeyProcessor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.html

ContextualFixedKeyProcessor<KIn, VIn, VOut>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.html

ContextualProcessor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ContextualProcessor.html

ContextualProcessor<KIn, VIn, KOut, VOut>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ContextualProcessor.html

FixedKeyProcessor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyProcessor.html

FixedKeyProcessorContext

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyProcessorContext.html

FixedKeyProcessorContext<KForward, VForward>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyProcessorContext.html

FixedKeyProcessorDirect

Direct override of FixedKeyProcessor or its generic type if there is one

FixedKeyProcessorDirect<KIn, VIn, VOut>

Direct override of FixedKeyProcessor or its generic type if there is one

FixedKeyProcessorSupplier<KIn, VIn, VOut>

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

FixedKeyProcessor<KIn, VIn, VOut>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyProcessor.html

FixedKeyRecord

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyRecord.html

FixedKeyRecord<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/FixedKeyRecord.html

InternalFixedKeyRecordFactory

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/InternalFixedKeyRecordFactory.html

ProcessingContext

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

Processor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/Processor.html

ProcessorContext

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ProcessorContext.html

ProcessorContext<KForward, VForward>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/ProcessorContext.html

ProcessorDirect

Direct override of Processor or its generic type if there is one

ProcessorDirect<KIn, VIn, KOut, VOut>

Direct override of Processor or its generic type if there is one

ProcessorSupplier<KIn, VIn, KOut, VOut>

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

Processor<KIn, VIn, KOut, VOut>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/Processor.html

Record

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/Record.html

RecordMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/RecordMetadata.html

Record<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/api/Record.html

Interfaces

IFixedKeyProcessorContext<KForward, VForward>

.NET interface for TO BE DEFINED FROM USER

IFixedKeyProcessorSupplier<KIn, VIn, VOut>

.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/FixedKeyProcessorSupplier.html

IFixedKeyProcessor<KIn, VIn, VOut>

.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

IProcessingContext

.NET interface for TO BE DEFINED FROM USER

IProcessorContext<KForward, VForward>

.NET interface for TO BE DEFINED FROM USER

IProcessorSupplier<KIn, VIn, KOut, VOut>

.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/ProcessorSupplier.html

IProcessor<KIn, VIn, KOut, VOut>

.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/3.9.0/org/apache/kafka/streams/processor/api/Processor.html

IRecordMetadata

.NET interface for TO BE DEFINED FROM USER