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

MINOR: update KafkaStreamsTelemetryIntegrationTest for Java17 (#19567) 

Reviewers: Bill Bejeck <bill@confluent.io>
This commit is contained in:
Matthias J. Sax 2025-04-25 16:43:18 -07:00 committed by GitHub
parent 2f9c2dd828
commit 0cf2f0e55d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java
View File

@ -83,7 +83,6 @@ import java.util.Map;
import java.util.Optional;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import static org.apache.kafka.common.utils.Utils.mkEntry;
@ -236,7 +235,7 @@ public class KafkaStreamsTelemetryIntegrationTest {
final String group = mn.group().replace("-metrics", "").replace('-', '.');
return "org.apache.kafka." + group + "." + name;
}).filter(name -> !name.equals("org.apache.kafka.stream.thread.state"))// telemetry reporter filters out string metrics
.sorted().collect(Collectors.toList());
.sorted().toList();
final List<String> actualMetrics = new ArrayList<>(TelemetryPlugin.SUBSCRIBED_METRICS.get(mainConsumerInstanceId));
assertEquals(expectedMetrics, actualMetrics);
@ -428,7 +427,7 @@ public class KafkaStreamsTelemetryIntegrationTest {
return streams.metadataForLocalThreads().stream()
.flatMap(threadMeta -> threadMeta.activeTasks().stream()
.map(taskMeta -> taskMeta.taskId().toString()))
.collect(Collectors.toList());
.toList();
}
private static Stream<Arguments> singleAndMultiTaskParameters() {
@ -626,7 +625,7 @@ public class KafkaStreamsTelemetryIntegrationTest {
.flatMap(sm -> sm.getMetricsList().stream())
.map(org.apache.kafka.shaded.io.opentelemetry.proto.metrics.v1.Metric::getName)
.sorted()
.collect(Collectors.toList());
.toList();
LOG.info("Found metrics {} for clientId={}", metricNames, clientId);
SUBSCRIBED_METRICS.put(clientId, metricNames);
} catch (final Exception e) {