From 81019b6e9fad53d6fcd065e550acbd29953b0629 Mon Sep 17 00:00:00 2001 From: TengYao Chi Date: Sat, 9 Nov 2024 23:39:55 +0800 Subject: [PATCH] MINOR: Delete unused member from KafkaAdminClient (#17729) Reviewers: Chia-Ping Tsai --- .../java/org/apache/kafka/clients/admin/KafkaAdminClient.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java index d03107c3756..ef46b49db6e 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java @@ -406,7 +406,6 @@ public class KafkaAdminClient extends AdminClient { private final long retryBackoffMs; private final long retryBackoffMaxMs; private final ExponentialBackoff retryBackoff; - private final boolean clientTelemetryEnabled; private final MetadataRecoveryStrategy metadataRecoveryStrategy; private final AdminFetchMetricsManager adminFetchMetricsManager; private final Optional clientTelemetryReporter; @@ -630,7 +629,6 @@ public class KafkaAdminClient extends AdminClient { CommonClientConfigs.RETRY_BACKOFF_EXP_BASE, retryBackoffMaxMs, CommonClientConfigs.RETRY_BACKOFF_JITTER); - this.clientTelemetryEnabled = config.getBoolean(AdminClientConfig.ENABLE_METRICS_PUSH_CONFIG); List reporters = CommonClientConfigs.metricsReporters(this.clientId, config); this.clientTelemetryReporter = clientTelemetryReporter; this.clientTelemetryReporter.ifPresent(reporters::add);