Skip to content

Commit 9d29700

Browse files
committed
fix kafka test
1 parent fcf854f commit 9d29700

File tree

1 file changed

+16
-15
lines changed

1 file changed

+16
-15
lines changed

jmx-metrics/src/integrationTest/java/io/opentelemetry/contrib/jmxmetrics/target_systems/KafkaIntegrationTest.java

Lines changed: 16 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -380,13 +380,14 @@ void endToEnd() {
380380
List<Consumer<Metric>> assertions = new ArrayList<>(kafkaBrokerAssertions());
381381
assertions.addAll(
382382
Arrays.asList(
383-
metric -> assertGauge(metric, "jvm.classes.loaded", "number of loaded classes", "1"),
383+
metric ->
384+
assertGauge(metric, "jvm.classes.loaded", "number of loaded classes", "{class}"),
384385
metric ->
385386
assertTypedSum(
386387
metric,
387388
"jvm.gc.collections.count",
388389
"total number of collections that have occurred",
389-
"1",
390+
"{collection}",
390391
Arrays.asList("G1 Young Generation", "G1 Old Generation")),
391392
metric ->
392393
assertTypedSum(
@@ -396,36 +397,36 @@ void endToEnd() {
396397
"ms",
397398
Arrays.asList("G1 Young Generation", "G1 Old Generation")),
398399
metric ->
399-
assertGauge(metric, "jvm.memory.heap.committed", "current heap usage", "by"),
400-
metric -> assertGauge(metric, "jvm.memory.heap.init", "current heap usage", "by"),
401-
metric -> assertGauge(metric, "jvm.memory.heap.max", "current heap usage", "by"),
402-
metric -> assertGauge(metric, "jvm.memory.heap.used", "current heap usage", "by"),
400+
assertGauge(metric, "jvm.memory.heap.committed", "current heap usage", "By"),
401+
metric -> assertGauge(metric, "jvm.memory.heap.init", "current heap usage", "By"),
402+
metric -> assertGauge(metric, "jvm.memory.heap.max", "current heap usage", "By"),
403+
metric -> assertGauge(metric, "jvm.memory.heap.used", "current heap usage", "By"),
403404
metric ->
404405
assertGauge(
405-
metric, "jvm.memory.nonheap.committed", "current non-heap usage", "by"),
406+
metric, "jvm.memory.nonheap.committed", "current non-heap usage", "By"),
406407
metric ->
407-
assertGauge(metric, "jvm.memory.nonheap.init", "current non-heap usage", "by"),
408+
assertGauge(metric, "jvm.memory.nonheap.init", "current non-heap usage", "By"),
408409
metric ->
409-
assertGauge(metric, "jvm.memory.nonheap.max", "current non-heap usage", "by"),
410+
assertGauge(metric, "jvm.memory.nonheap.max", "current non-heap usage", "By"),
410411
metric ->
411-
assertGauge(metric, "jvm.memory.nonheap.used", "current non-heap usage", "by"),
412+
assertGauge(metric, "jvm.memory.nonheap.used", "current non-heap usage", "By"),
412413
metric ->
413414
assertTypedGauge(
414415
metric,
415416
"jvm.memory.pool.committed",
416417
"current memory pool usage",
417-
"by",
418+
"By",
418419
gcLabels),
419420
metric ->
420421
assertTypedGauge(
421-
metric, "jvm.memory.pool.init", "current memory pool usage", "by", gcLabels),
422+
metric, "jvm.memory.pool.init", "current memory pool usage", "By", gcLabels),
422423
metric ->
423424
assertTypedGauge(
424-
metric, "jvm.memory.pool.max", "current memory pool usage", "by", gcLabels),
425+
metric, "jvm.memory.pool.max", "current memory pool usage", "By", gcLabels),
425426
metric ->
426427
assertTypedGauge(
427-
metric, "jvm.memory.pool.used", "current memory pool usage", "by", gcLabels),
428-
metric -> assertGauge(metric, "jvm.threads.count", "number of threads", "1")));
428+
metric, "jvm.memory.pool.used", "current memory pool usage", "By", gcLabels),
429+
metric -> assertGauge(metric, "jvm.threads.count", "number of threads", "{thread}")));
429430

430431
waitAndAssertMetrics(assertions);
431432
}

0 commit comments

Comments
 (0)