TopologyDescription.Source
is the extension of the Node contract for source nodes that can have comma-separated topic names, topic names, and topic pattern.
Method | Description |
---|---|
|
Pattern topicPattern() Used when…FIXME |
|
String topics() Used when…FIXME |
|
Set<String> topicSet() Used when…FIXME |
Note
|
InternalTopologyBuilder.Source is the default and only known implementation of the TopologyDescription.Source Contract in Kafka Streams. |