TopologyDescription.Sink

TopologyDescription.Sink is the extension of the Node contract for sink nodes that can have a topic and TopicNameExtractor.

Table 1. TopologyDescription.Sink Contract
Method Description

topic

String topic()

Used when…​FIXME

topicNameExtractor

TopicNameExtractor topicNameExtractor()

Used when…​FIXME

Note
InternalTopologyBuilder.Sink is the default and only known implementation of the TopologyDescription.Sink Contract in Kafka Streams.

results matching ""

    No results matching ""