SourceNode¶

SourceNode is a ProcessorNode.

Creating Instance¶

SourceNode takes the following to be created:

• Node Name
• TimestampExtractor
• Key Deserializer
• Value Deserializer

SourceNode is created when:

• SourceNodeFactory is requested to build a ProcessorNode