root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Delete unused member from KafkaAdminClient (#17729) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
TengYao Chi 2024-11-09 23:39:55 +08:00 committed by GitHub
parent 4e3a3d398d
commit 81019b6e9f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
View File

@ -406,7 +406,6 @@ public class KafkaAdminClient extends AdminClient {
private final long retryBackoffMs; private final long retryBackoffMs;
private final long retryBackoffMaxMs; private final long retryBackoffMaxMs;
private final ExponentialBackoff retryBackoff; private final ExponentialBackoff retryBackoff;
private final boolean clientTelemetryEnabled;
private final MetadataRecoveryStrategy metadataRecoveryStrategy; private final MetadataRecoveryStrategy metadataRecoveryStrategy;
private final AdminFetchMetricsManager adminFetchMetricsManager; private final AdminFetchMetricsManager adminFetchMetricsManager;
private final Optional<ClientTelemetryReporter> clientTelemetryReporter; private final Optional<ClientTelemetryReporter> clientTelemetryReporter;
@ -630,7 +629,6 @@ public class KafkaAdminClient extends AdminClient {
CommonClientConfigs.RETRY_BACKOFF_EXP_BASE, CommonClientConfigs.RETRY_BACKOFF_EXP_BASE,
retryBackoffMaxMs, retryBackoffMaxMs,
CommonClientConfigs.RETRY_BACKOFF_JITTER); CommonClientConfigs.RETRY_BACKOFF_JITTER);
this.clientTelemetryEnabled = config.getBoolean(AdminClientConfig.ENABLE_METRICS_PUSH_CONFIG);
List<MetricsReporter> reporters = CommonClientConfigs.metricsReporters(this.clientId, config); List<MetricsReporter> reporters = CommonClientConfigs.metricsReporters(this.clientId, config);
this.clientTelemetryReporter = clientTelemetryReporter; this.clientTelemetryReporter = clientTelemetryReporter;
this.clientTelemetryReporter.ifPresent(reporters::add); this.clientTelemetryReporter.ifPresent(reporters::add);