SourceNodeFactory¶

SourceNodeFactory is a NodeFactory with no predecessors.

Creating Instance¶

SourceNodeFactory takes the following to be created:

• Node Name
• Topics
• Topic Pattern
• TimestampExtractor
• Key Deserializer
• Value Deserializer

SourceNodeFactory is created when:

• InternalTopologyBuilder is requested to addSource and addGlobalStore