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 ""