Package org.apache.kafka.streams.processor.internals

Class InternalTopologyBuilder.Source

java.lang.Object

org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode

org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.Source

All Implemented Interfaces:

TopologyDescription.Node, TopologyDescription.Source

Enclosing class:

InternalTopologyBuilder

public static final class InternalTopologyBuilder.Source
extends InternalTopologyBuilder.AbstractNode
implements TopologyDescription.Source

Constructor Summary

Constructors

Constructor	Description
Source(String name, Set<String> topics, Pattern pattern)

Method Summary

Modifier and Type	Method	Description
void	addPredecessor(TopologyDescription.Node predecessor)
boolean	equals(Object o)
int	hashCode()
Pattern	topicPattern()	The pattern used to match topic names that is reading from.
String	topics()	Deprecated.
Set<String>	topicSet()	The topic names this source node is reading from.
String	toString()

Methods inherited from class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode

addSuccessor, name, predecessors, successors

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

name, predecessors, successors

Constructor Detail

Source

public Source(String name,
              Set<String> topics,
              Pattern pattern)

Method Detail

topics

@Deprecated
public String topics()

Deprecated.

Description copied from interface: TopologyDescription.Source

The topic names this source node is reading from.

Specified by:

topics in interface TopologyDescription.Source

Returns:

comma separated list of topic names or pattern (as String)

topicSet

public Set<String> topicSet()

Description copied from interface: TopologyDescription.Source

The topic names this source node is reading from.

Specified by:

topicSet in interface TopologyDescription.Source

Returns:

a set of topic names

topicPattern

public Pattern topicPattern()

Description copied from interface: TopologyDescription.Source

The pattern used to match topic names that is reading from.

Specified by:

topicPattern in interface TopologyDescription.Source

Returns:

the pattern used to match topic names

addPredecessor

public void addPredecessor(TopologyDescription.Node predecessor)

Overrides:

addPredecessor in class InternalTopologyBuilder.AbstractNode

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object