Constructor and Description |
---|
KTableSuppressProcessor(SuppressedInternal<K> suppress,
java.lang.String storeName,
org.apache.kafka.common.serialization.Serde<K> keySerde,
FullChangeSerde<V> valueSerde) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this processor and clean up any resources.
|
void |
init(ProcessorContext context)
Initialize this processor with the given context.
|
void |
process(K key,
Change<V> value)
Process the record with the given key and value.
|
public KTableSuppressProcessor(SuppressedInternal<K> suppress, java.lang.String storeName, org.apache.kafka.common.serialization.Serde<K> keySerde, FullChangeSerde<V> valueSerde)
public void init(ProcessorContext context)
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, to
schedule
a method to be
called periodically
and to access attached StateStore
s.
public void process(K key, Change<V> value)
Processor
public void close()
Processor
Processor.close()
is called after an internal cleanup.
Thus, it is not possible to write anything to Kafka as underlying clients are already closed. The framework may
later re-use this processor by calling #init()
on it again.
Note: Do not close any streams managed resources, like StateStore
s here, as they are managed by the library.