From 49467c0600a5c722d10b6c187ab41bf5f68396da Mon Sep 17 00:00:00 2001 From: Denys Fakhritdinov Date: Thu, 11 Jul 2024 16:08:28 +0200 Subject: [PATCH] Update modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com> --- .../evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala b/modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala index 30aa892f..bc5cf9e2 100644 --- a/modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala +++ b/modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala @@ -22,7 +22,8 @@ object ConsumerMetricsOf { override def poll(topic: Topic, bytes: Int, records: Int, age: Option[FiniteDuration]): F[Unit] = source.poll(topic, bytes, records, age) - override def count(name: String, topic: Topic): F[Unit] = source.count(name, topic) + override def count(name: String, topic: Topic): F[Unit] = + source.count(name, topic) override def rebalance(name: String, topicPartition: TopicPartition): F[Unit] = source.rebalance(name, topicPartition)