AbstractProcessorContext |
|
AbstractTask |
|
ClientUtils |
|
ClientUtils.QuietAdminClientConfig |
|
DefaultKafkaClientSupplier |
|
DefaultStreamPartitioner<K,V> |
|
ForwardingDisabledProcessorContext |
ProcessorContext implementation that will throw on any forward call.
|
GlobalProcessorContextImpl |
|
GlobalStateManagerImpl |
This class is responsible for the initialization, restoration, closing, flushing etc
of Global State Stores.
|
GlobalStateUpdateTask |
Updates the state for all Global State Stores.
|
GlobalStreamThread |
This is the thread responsible for keeping all Global State Stores updated.
|
InternalTopicConfig |
InternalTopicConfig captures the properties required for configuring
the internal topics we create for change-logs and repartitioning etc.
|
InternalTopicManager |
|
InternalTopicProperties |
|
InternalTopologyBuilder |
|
InternalTopologyBuilder.AbstractNode |
|
InternalTopologyBuilder.GlobalStore |
|
InternalTopologyBuilder.Processor |
|
InternalTopologyBuilder.Sink<K,V> |
|
InternalTopologyBuilder.Source |
|
InternalTopologyBuilder.StateStoreFactory<S extends StateStore> |
|
InternalTopologyBuilder.Subtopology |
|
InternalTopologyBuilder.TopicsInfo |
|
InternalTopologyBuilder.TopologyDescription |
|
PartitionGroup |
PartitionGroup is used to buffer all co-partitioned records for processing.
|
ProcessorContextImpl |
|
ProcessorContextUtils |
This class bridges the gap for components that _should_ be compatible with
the public ProcessorContext interface, but have come to depend on features
in InternalProcessorContext.
|
ProcessorNode<K,V> |
|
ProcessorRecordContext |
|
ProcessorStateManager |
ProcessorStateManager is the source of truth for the current offset for each state store,
which is either the read offset during restoring, or the written offset during normal processing.
|
ProcessorStateManager.StateStoreMetadata |
|
ProcessorTopology |
|
PunctuationQueue |
|
PunctuationSchedule |
|
QuickUnion<T> |
|
RecordCollectorImpl |
|
RecordQueue |
RecordQueue is a FIFO queue of StampedRecord (ConsumerRecord + timestamp).
|
RepartitionTopicConfig |
RepartitionTopicConfig captures the properties required for configuring
the repartition topics.
|
SinkNode<K,V> |
|
SourceNode<K,V> |
|
Stamped<V> |
|
StampedRecord |
|
StandbyTask |
A StandbyTask
|
StateDirectory |
Manages the directories where the state of Tasks owned by a StreamThread are
stored.
|
StateRestoreCallbackAdapter |
|
StaticTopicNameExtractor<K,V> |
Static topic name extractor
|
StoreChangelogReader |
ChangelogReader is created and maintained by the stream thread and used for both updating standby tasks and
restoring active tasks.
|
StreamsMetadataState |
|
StreamsPartitionAssignor |
|
StreamsProducer |
StreamsProducer manages the producers within a Kafka Streams application.
|
StreamsRebalanceListener |
|
StreamTask |
A StreamTask is associated with a PartitionGroup , and is assigned to a StreamThread for processing.
|
StreamThread |
|
TaskManager |
|
TestDriverProducer |
|
ToInternal |
|
UnwindowedChangelogTopicConfig |
UnwindowedChangelogTopicConfig captures the properties required for configuring
the un-windowed store changelog topics.
|
WindowedChangelogTopicConfig |
WindowedChangelogTopicConfig captures the properties required for configuring
the windowed store changelog topics.
|