Package org.apache.kafka.streams.processor
package org.apache.kafka.streams.processor
-
ClassDescriptionAbstractProcessor<K,
V> Deprecated.Since 3.0.Interface for batching restoration of aStateStoreIt is expected that implementations of this class will not call theStateRestoreCallback.restore(byte[], byte[])method.Cancellable interface returned inProcessorContext.schedule(Duration, PunctuationType, Punctuator).Stores can register this callback to be notified upon successful commit.Provides a set ofStoreBuilders that will be automatically added to the topology and connected to the associated processor.Retrieves embedded metadata timestamps from Kafka messages.Retrieves embedded metadata timestamps from Kafka messages.MockProcessorContextis a mock ofProcessorContextfor users to test theirProcessor,Transformer, andValueTransformerimplementations.MockProcessorContext.CapturedPunctuatorholds captured punctuators, along with their scheduling information.Processor<K,V> Deprecated.Since 3.0.Processor context interface.ProcessorSupplier<K,V> Deprecated.Since 3.0.Controls what notion of time is used for punctuation scheduled viaProcessorContext.schedule(Duration, PunctuationType, Punctuator)schedule}: STREAM_TIME - uses "stream time", which is advanced by the processing of messages in accordance with the timestamp as extracted by theTimestampExtractorin use.A functional interface used as an argument toProcessorContext.schedule(Duration, PunctuationType, Punctuator).The context associated with the current record being processed by anProcessorRestoration logic for log-backed state stores upon restart, it takes one record at a time from the logs to apply to the restoring state.Class for listening to various states of the restoration process of a StateStore.A storage engine for managing state maintained by a stream processor.State store context interface.StreamPartitioner<K,V> Determine how records are distributed among the partitions in a Kafka topic.The task ID representation composed as subtopology (aka topicGroupId) plus the assigned partition ID.Deprecated.since 3.0, useTaskMetadatainstead.Deprecated.since 3.0 useThreadMetadatainsteadAn interface that allows the Kafka Streams framework to extract a timestamp from an instance ofConsumerRecord.This class is used to provide the optional parameters when sending output records to downstream processor usingProcessorContext.forward(Object, Object, To).TopicNameExtractor<K,V> An interface that allows to dynamically determine the name of the Kafka topic to send at the sink node of the topology.Retrieves embedded metadata timestamps from Kafka messages.Retrieves current wall clock timestamps asSystem.currentTimeMillis().