Class Hierarchy
- java.lang.Object
- 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>
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.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)