Skip to content

Commit 00ebd57

Browse files
committed
fix build error
1 parent e2deea8 commit 00ebd57

File tree

7 files changed

+22
-18
lines changed

7 files changed

+22
-18
lines changed

Diff for: clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -3747,8 +3747,8 @@ private MetricName expectedMetricName(String clientId, String config, Class<?> c
37473747
private static final String NAME = "name";
37483748
private static final String DESCRIPTION = "description";
37493749
private static final LinkedHashMap<String, String> TAGS = new LinkedHashMap<>() {{
3750-
put("k", "v");
3751-
}};
3750+
put("k", "v");
3751+
}};
37523752
private static final double VALUE = 123.0;
37533753

37543754
public static class MonitorableDeserializer extends MockDeserializer implements Monitorable {

Diff for: clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -2882,8 +2882,8 @@ private MetricName expectedMetricName(String clientId, String config, Class<?> c
28822882
private static final String NAME = "name";
28832883
private static final String DESCRIPTION = "description";
28842884
private static final LinkedHashMap<String, String> TAGS = new LinkedHashMap<>() {{
2885-
put("k", "v");
2886-
}};
2885+
put("k", "v");
2886+
}};
28872887
private static final double VALUE = 123.0;
28882888

28892889
public static class MonitorableSerializer extends MockSerializer implements Monitorable {

Diff for: clients/src/test/java/org/apache/kafka/common/metrics/internals/PluginMetricsImplTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@
3535

3636
public class PluginMetricsImplTest {
3737

38-
private final LinkedHashMap<String, String> extraTags = new LinkedHashMap<>(){{
39-
put("my-tag", "my-value");
40-
}};
38+
private final LinkedHashMap<String, String> extraTags = new LinkedHashMap<>() {{
39+
put("my-tag", "my-value");
40+
}};
4141
private Map<String, String> tags;
4242
private Metrics metrics;
4343
private int initialMetrics;

Diff for: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -64,9 +64,9 @@ public class ConnectMetricsTest {
6464
WorkerConfig.KEY_CONVERTER_CLASS_CONFIG, "org.apache.kafka.connect.json.JsonConverter",
6565
WorkerConfig.VALUE_CONVERTER_CLASS_CONFIG, "org.apache.kafka.connect.json.JsonConverter");
6666
private static final ConnectorTaskId CONNECTOR_TASK_ID = new ConnectorTaskId("connector", 0);
67-
private static final LinkedHashMap<String, String> TAGS = new LinkedHashMap<>(){{
68-
put("t1", "v1");
69-
}};
67+
private static final LinkedHashMap<String, String> TAGS = new LinkedHashMap<>() {{
68+
put("t1", "v1");
69+
}};
7070

7171
private ConnectMetrics metrics;
7272

Diff for: metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java

+5-4
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
import java.util.ArrayList;
4040
import java.util.HashMap;
4141
import java.util.HashSet;
42+
import java.util.LinkedHashMap;
4243
import java.util.List;
4344
import java.util.Map;
4445
import java.util.Set;
@@ -230,21 +231,21 @@ private class AuthorizerMetrics {
230231
private AuthorizerMetrics(PluginMetrics metrics) {
231232
authorizationAllowedSensor = metrics.addSensor("authorizer-authorization-allowed");
232233
authorizationAllowedSensor.add(
233-
metrics.metricName("authorization-allowed-rate-per-minute", "The number of authorization allowed per minute", Map.of()),
234+
metrics.metricName("authorization-allowed-rate-per-minute", "The number of authorization allowed per minute", new LinkedHashMap<>()),
234235
new Rate(TimeUnit.MINUTES, new WindowedCount()));
235236

236237
authorizationDeniedSensor = metrics.addSensor("authorizer-authorization-denied");
237238
authorizationDeniedSensor.add(
238-
metrics.metricName("authorization-denied-rate-per-minute", "The number of authorization denied per minute", Map.of()),
239+
metrics.metricName("authorization-denied-rate-per-minute", "The number of authorization denied per minute", new LinkedHashMap<>()),
239240
new Rate(TimeUnit.MINUTES, new WindowedCount()));
240241

241242
authorizationRequestSensor = metrics.addSensor("authorizer-authorization-request");
242243
authorizationRequestSensor.add(
243-
metrics.metricName("authorization-request-rate-per-minute", "The number of authorization request per minute", Map.of()),
244+
metrics.metricName("authorization-request-rate-per-minute", "The number of authorization request per minute", new LinkedHashMap<>()),
244245
new Rate(TimeUnit.MINUTES, new WindowedCount()));
245246

246247
metrics.addMetric(
247-
metrics.metricName("acls-total-count", "The number of acls defined", Map.of()),
248+
metrics.metricName("acls-total-count", "The number of acls defined", new LinkedHashMap<>()),
248249
(Gauge<Integer>) (config, now) -> aclCount());
249250
}
250251

Diff for: server/src/test/java/org/apache/kafka/security/authorizer/AuthorizerUtilsTest.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import org.junit.jupiter.params.ParameterizedTest;
3939
import org.junit.jupiter.params.provider.EnumSource;
4040

41+
import java.util.LinkedHashMap;
4142
import java.util.List;
4243
import java.util.Map;
4344
import java.util.concurrent.CompletionStage;
@@ -84,7 +85,9 @@ public void testCreateAuthorizer(ProcessRole role) throws ClassNotFoundException
8485

8586
public static class MonitorableAuthorizer implements Authorizer, Monitorable {
8687

87-
private final Map<String, String> extraTags = Map.of("k1", "v1");
88+
private final LinkedHashMap<String, String> extraTags = new LinkedHashMap<>() {{
89+
put("k1", "v1");
90+
}};
8891
private final AtomicInteger counter = new AtomicInteger();
8992
private boolean configured = false;
9093
private MetricName metricName = null;

Diff for: server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ public static class MonitorableNoOpRemoteLogMetadataManager extends NoOpRemoteLo
113113

114114
@Override
115115
public void withPluginMetrics(PluginMetrics metrics) {
116-
MetricName name = metrics.metricName("name", "description", Map.of());
116+
MetricName name = metrics.metricName("name", "description", new LinkedHashMap<>());
117117
metrics.addMetric(name, (Measurable) (config, now) -> 123);
118118
}
119119
}
@@ -124,7 +124,7 @@ public static class MonitorableReplicaSelector extends RackAwareReplicaSelector
124124

125125
@Override
126126
public void withPluginMetrics(PluginMetrics metrics) {
127-
MetricName name = metrics.metricName("name", "description", Map.of());
127+
MetricName name = metrics.metricName("name", "description", new LinkedHashMap<>());
128128
metrics.addMetric(name, (Measurable) (config, now) -> 123);
129129
}
130130
}
@@ -135,7 +135,7 @@ public static class MonitorableNoOpRemoteStorageManager extends NoOpRemoteStorag
135135

136136
@Override
137137
public void withPluginMetrics(PluginMetrics metrics) {
138-
MetricName name = metrics.metricName("name", "description", Map.of());
138+
MetricName name = metrics.metricName("name", "description", new LinkedHashMap<>());
139139
metrics.addMetric(name, (Measurable) (config, now) -> 123);
140140
}
141141
}

0 commit comments

Comments
 (0)