0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

minor fx

Browse source
This commit is contained in:
iliax 2023-07-26 12:30:37 +04:00
parent 4f27a39b68
commit f9ba54317b
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/metrics/sink/KafkaSink.java
View file

@ -1,6 +1,5 @@
package com.provectus.kafka.ui.service.metrics.sink; package com.provectus.kafka.ui.service.metrics.sink;
import static com.google.common.base.Charsets.UTF_8;
import static com.provectus.kafka.ui.service.MessagesService.createProducer; import static com.provectus.kafka.ui.service.MessagesService.createProducer;
import static com.provectus.kafka.ui.service.metrics.prometheus.PrometheusExpose.escapedLabelValue; import static com.provectus.kafka.ui.service.metrics.prometheus.PrometheusExpose.escapedLabelValue;
import static io.prometheus.client.Collector.MetricFamilySamples; import static io.prometheus.client.Collector.MetricFamilySamples;
@ -68,7 +67,7 @@ class KafkaSink implements MetricsSink {
@SneakyThrows @SneakyThrows
private static byte[] toJsonBytes(KafkaMetric m) { private static byte[] toJsonBytes(KafkaMetric m) {
return JSON_MAPPER.writeValueAsString(m).getBytes(UTF_8); return JSON_MAPPER.writeValueAsBytes(m);
} }
} }