Class Hierarchy
- java.lang.Object
- org.apache.kafka.streams.processor.api.ContextualProcessor<KIn,
VIn, KOut, VOut> (implements org.apache.kafka.streams.processor.api.Processor<KIn, VIn, KOut, VOut>) - org.apache.kafka.streams.processor.api.MockProcessorContext<KForward,
VForward> (implements org.apache.kafka.streams.processor.api.ProcessorContext<KForward, VForward>, org.apache.kafka.streams.processor.internals.RecordCollector.Supplier) - org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedForward<K,
V> - org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedPunctuator
- org.apache.kafka.streams.processor.api.Record<K,
V>
- org.apache.kafka.streams.processor.api.ContextualProcessor<KIn,
Interface Hierarchy
- org.apache.kafka.streams.processor.ConnectedStoreProvider
- org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,
VIn, KOut, VOut> (also extends java.util.function.Supplier<T>)
- org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,
- org.apache.kafka.streams.processor.api.Processor<KIn,
VIn, KOut, VOut> - org.apache.kafka.streams.processor.api.ProcessorContext<KForward,
VForward> - org.apache.kafka.streams.processor.api.RecordMetadata
- java.util.function.Supplier<T>
- org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,
VIn, KOut, VOut> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
- org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,