Skip to content

Commit

Permalink
remove _total suffix from compressor metrics (#573)
Browse files Browse the repository at this point in the history
  • Loading branch information
Z1kkurat committed Dec 11, 2023
1 parent fdcb510 commit 5baa0cc
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,14 +31,14 @@ object CompressorMetrics {

def compressorMetricsOf[F[_]: Monad](registry: CollectorRegistry[F]): Resource[F, CompressorMetricsOf[F]] = {
val rawBytesSummary = registry.summary(
name = "kafka_flow_compressor_raw_bytes_total",
name = "kafka_flow_compressor_raw_bytes",
help = "Payload size in bytes before compression",
quantiles = Quantiles(Quantile(value = 0.9, error = 0.05), Quantile(value = 0.99, error = 0.005)),
labels = LabelNames("component")
)

val compressedSummary = registry.summary(
name = "kafka_flow_compressor_compressed_bytes_total",
name = "kafka_flow_compressor_compressed_bytes",
help = "Payload size in bytes after compression",
quantiles = Quantiles(Quantile(value = 0.9, error = 0.05), Quantile(value = 0.99, error = 0.005)),
labels = LabelNames("component")
Expand Down

0 comments on commit 5baa0cc

Please sign in to comment.