Class AbstractProcessor<K,V>
java.lang.Object
org.apache.kafka.streams.processor.AbstractProcessor<K,V>
- Type Parameters:
K
- the type of keysV
- the type of values
- All Implemented Interfaces:
Processor<K,
V>
Deprecated.
An abstract implementation of
Processor
that manages the ProcessorContext
instance and provides default no-op
implementation of close()
.-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Deprecated.Close this processor and clean up any resources.protected final ProcessorContext
context()
Deprecated.Get the processor's context set duringinitialization
.void
init
(ProcessorContext context) Deprecated.Initialize this processor with the given context.
-
Field Details
-
context
Deprecated.
-
-
Constructor Details
-
AbstractProcessor
protected AbstractProcessor()Deprecated.
-
-
Method Details
-
init
Deprecated.Description copied from interface:Processor
Initialize this processor with the given context. The framework ensures this is called once per processor when the topology that contains it is initialized. When the framework is done with the processor,Processor.close()
will be called on it; the framework may later re-use the processor by calling#init()
again.The provided
context
can be used to access topology and record meta data, toschedule
a method to becalled periodically
and to access attachedStateStore
s. -
close
public void close()Deprecated.Close this processor and clean up any resources.This method does nothing by default; if desired, subclasses should override it with custom functionality.
-
context
Deprecated.Get the processor's context set duringinitialization
.- Returns:
- the processor context; null only when called prior to
initialization
.
-
Processor
orContextualProcessor
instead.