mirror of https://github.com/apache/kafka.git
KAFKA-12810: Remove deprecated TopologyDescription.Source#topics (#10727)
Removes methods that were deprecated via KIP-321. Reviewers: Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
parent
bb48cf33b3
commit
b58da356be
|
|
@ -113,13 +113,6 @@ public interface TopologyDescription {
|
|||
* A source node of a topology.
|
||||
*/
|
||||
interface Source extends Node {
|
||||
/**
|
||||
* The topic names this source node is reading from.
|
||||
* @return comma separated list of topic names or pattern (as String)
|
||||
* @deprecated use {@link #topicSet()} or {@link #topicPattern()} instead
|
||||
*/
|
||||
@Deprecated
|
||||
String topics();
|
||||
|
||||
/**
|
||||
* The topic names this source node is reading from.
|
||||
|
|
|
|||
|
|
@ -1589,12 +1589,6 @@ public class InternalTopologyBuilder {
|
|||
this.topicPattern = pattern;
|
||||
}
|
||||
|
||||
@Deprecated
|
||||
@Override
|
||||
public String topics() {
|
||||
return topics.toString();
|
||||
}
|
||||
|
||||
@Override
|
||||
public Set<String> topicSet() {
|
||||
return topics;
|
||||
|
|
|
|||
Loading…
Reference in New Issue