SourceNodeFactory — NodeFactory With No Predecessors

SourceNodeFactory is a NodeFactory that has no predecessors.

SourceNodeFactory is created when InternalTopologyBuilder is requested to register a global state store or source topic.

Note
SourceNodeFactory is an internal private class of InternalTopologyBuilder.

Creating SourceNodeFactory Instance

SourceNodeFactory takes the following when created:

  • Node name

  • Topic names

  • Topic pattern

  • TimestampExtractor

  • Key deserializer

  • Value deserializer

Building ProcessorNode — build Method

ProcessorNode build()
Note
build is part of NodeFactory Contract to build a processor node.

build creates a SourceNode with the name and the source topic names (as recorded in the nodeToSourceTopics internal registry).

Internally, build looks up the node name in the nodeToSourceTopics internal registry to find the topic names (the node is attached to).

build creates a SourceNode with the name, the source topic names (possibly decorated if internal), and the other properties, i.e. the timestampExtractor, the keyDeserializer and the valDeserializer

It is (hardly) possible that no topic names could be found, but when it happens, build creates a SourceNode with the pattern (and the other properties, i.e. the name, the timestampExtractor, the keyDeserializer and the valDeserializer).

results matching ""

    No results matching ""