TopologyDescription.Source

TopologyDescription.Source is the extension of the Node contract for source nodes that can have comma-separated topic names, topic names, and topic pattern.

Table 1. TopologyDescription.Source Contract
Method Description

topicPattern

 
Pattern topicPattern()

Used when…​FIXME

topics

 
String topics()

Used when…​FIXME

topicSet

 
Set<String> topicSet()

Used when…​FIXME
Note
 InternalTopologyBuilder.Source is the default and only known implementation of the TopologyDescription.Source Contract in Kafka Streams.

results matching ""

    No results matching ""