kafka-streams-internals-SourceNode.adoc

SourceNode

SourceNode is a ProcessorNode that…​FIXME

SourceNode is created exclusively when SourceNodeFactory is requested to build a processor node (when…​FIXME)

SourceNode gets a ProcessorContext when initialized. It is later used when SourceNode processes a record (and simply forwards it downstream).

init Method

void init(ProcessorContext context)

Note	init is part of ProcessorNode Contract to…​FIXME.

init…​FIXME

Processing Record — process Method

void process(
  K key,
  V value)

Note	process is part of ProcessorNode Contract to…​FIXME.

process simply requests ProcessorContext to forward followed by informing the sourceNodeForwardSensor that a record was processed.

Creating SourceNode Instance

SourceNode takes the following when created:

• Node name

• List of topics

• TimestampExtractor

• Key deserializer

• Value deserializer

SourceNode initializes the internal registries and counters.