This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 22ed71a2c21 KAFKA-17602 Remove
`ConfigUtils.translateDeprecatedConfigs` from JmxReporter (#17267)
22ed71a2c21 is described below
commit 22ed71a2c21699006d83d8448b85b1fe313f1a21
Author: xijiu <[email protected]>
AuthorDate: Thu Sep 26 03:43:24 2024 +0800
KAFKA-17602 Remove `ConfigUtils.translateDeprecatedConfigs` from
JmxReporter (#17267)
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../src/main/java/org/apache/kafka/common/metrics/JmxReporter.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java
b/clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java
index 7f7eda4ba38..7b7b9d8635b 100644
--- a/clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java
+++ b/clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java
@@ -19,7 +19,6 @@ package org.apache.kafka.common.metrics;
import org.apache.kafka.common.KafkaException;
import org.apache.kafka.common.MetricName;
import org.apache.kafka.common.config.ConfigException;
-import org.apache.kafka.common.utils.ConfigUtils;
import org.apache.kafka.common.utils.Sanitizer;
import org.apache.kafka.common.utils.Utils;
@@ -305,10 +304,7 @@ public class JmxReporter implements MetricsReporter {
}
- public static Predicate<String> compilePredicate(Map<String, ?>
originalConfig) {
- Map<String, ?> configs = ConfigUtils.translateDeprecatedConfigs(
- originalConfig, new String[][]{{INCLUDE_CONFIG},
- {EXCLUDE_CONFIG}});
+ public static Predicate<String> compilePredicate(Map<String, ?> configs) {
String include = (String) configs.get(INCLUDE_CONFIG);
String exclude = (String) configs.get(EXCLUDE_CONFIG);