Skip to content

Commit 45df794

Browse files
committed
[hotfix] Remove unused method
1 parent a84c2b8 commit 45df794

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -31,15 +31,6 @@ class KafkaSubscriberUtils {
3131

3232
private KafkaSubscriberUtils() {}
3333

34-
static Map<String, TopicDescription> getAllTopicMetadata(AdminClient adminClient) {
35-
try {
36-
Set<String> allTopicNames = adminClient.listTopics().names().get();
37-
return getTopicMetadata(adminClient, allTopicNames);
38-
} catch (Exception e) {
39-
throw new RuntimeException("Failed to get metadata for all topics.", e);
40-
}
41-
}
42-
4334
static Map<String, TopicDescription> getTopicMetadata(
4435
AdminClient adminClient, Pattern topicPattern) {
4536
try {

0 commit comments

Comments
 (0)