This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 45df794b [hotfix] Remove unused method
45df794b is described below
commit 45df794b4d8fb7094ebd757d4f842bbb44ff07c6
Author: Rui Fan <fan...@apache.org>
AuthorDate: Tue Jan 21 17:15:52 2025 +0800
[hotfix] Remove unused method
---
.../kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java
index 72e7f64d..478e3a35 100644
---
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java
+++
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java
@@ -31,15 +31,6 @@ class KafkaSubscriberUtils {
private KafkaSubscriberUtils() {}
- static Map<String, TopicDescription> getAllTopicMetadata(AdminClient
adminClient) {
- try {
- Set<String> allTopicNames = adminClient.listTopics().names().get();
- return getTopicMetadata(adminClient, allTopicNames);
- } catch (Exception e) {
- throw new RuntimeException("Failed to get metadata for all
topics.", e);
- }
- }
-
static Map<String, TopicDescription> getTopicMetadata(
AdminClient adminClient, Pattern topicPattern) {
try {
