[gobblin] branch master updated: add an API in AbstractBaseKafkaConsumerClient to list selected topics (#3501)

[zihanli58]

This is an automated email from the ASF dual-hosted git repository.

zihanli58 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 9c0fc8f99 add an API in AbstractBaseKafkaConsumerClient to list 
selected topics (#3501)
9c0fc8f99 is described below

commit 9c0fc8f9989152d63c450712d6abd08bf7253538
Author: Arjun Singh Bora <ab...@linkedin.com>
AuthorDate: Mon May 23 10:57:47 2022 -0700

    add an API in AbstractBaseKafkaConsumerClient to list selected topics 
(#3501)
---
 .../gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java    | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java
 
b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java
index 2a0bc2be7..3933adb3c 100644
--- 
a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java
+++ 
b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java
@@ -162,4 +162,13 @@ public abstract class AbstractBaseKafkaConsumerClient 
implements GobblinKafkaCon
    * Get a list of all kafka topics
    */
   public abstract List<KafkaTopic> getTopics();
+
+  /**
+   * Get a list of {@link KafkaTopic} with the provided topic names.
+   * The default implementation lists all the topics.
+   * Implementations of this class can improve this method.
+   */
+  public Collection<KafkaTopic> getTopics(Collection<String> topics) {
+    return getTopics();
+  }
 }