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