Package org.apache.kafka.streams

Interface TopologyDescription.Sink

All Superinterfaces:

TopologyDescription.Node

Enclosing interface:

TopologyDescription

public static interface TopologyDescription.Sink
extends TopologyDescription.Node

A sink node of a topology.

Method Summary

Modifier and Type	Method	Description
String	topic()	The topic name this sink node is writing to.
TopicNameExtractor<?,?>	topicNameExtractor()	The TopicNameExtractor class that this sink node uses to dynamically extract the topic name to write to.

Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node

name, predecessors, successors

Method Details

topic

String topic()

The topic name this sink node is writing to. Could be null if the topic name can only be dynamically determined based on TopicNameExtractor

Returns:

a topic name

topicNameExtractor

TopicNameExtractor<?,?> topicNameExtractor()

The TopicNameExtractor class that this sink node uses to dynamically extract the topic name to write to. Could be null if the topic name is not dynamically determined.

Returns:

the TopicNameExtractor class used get the topic name