SinkNodeFactory

SinkNodeFactory is a custom NodeFactory that can build and describe a SinkNode.

SinkNodeFactory is created exclusively when InternalTopologyBuilder is requested to register a sink.

Building SinkNode — build Method

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

build simply creates a SinkNode (with the name, the key serializer, the value serializer and the StreamPartitioner).

Note
 The name of the topic of the SinkNode is the topic with application id for an internal topic.

Creating SinkNodeFactory Instance

SinkNodeFactory takes the following when created:

  • Node name

  • Names of the predecessors

  • Topic name

  • Key Serializer

  • Value Serializer

  • StreamPartitioner

Describing SinkNode — describe Method

Sink describe()
Note
 describe is part of NodeFactory Contract to describe a processor node.

describe…​FIXME

results matching ""

    No results matching ""