ProcessorNode build()
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.
|
Building ProcessorNode — build Method
|
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).