TopologyDescription.Sink (kafka 3.0.2 API)

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