Skip to content

Commit

Permalink
Update modules/metrics/src/main/scala/com/evolutiongaming/skafka/cons…
Browse files Browse the repository at this point in the history
…umer/ConsumerMetricsOf.scala

Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com>
  • Loading branch information
dfakhritdinov and mr-git committed Jul 11, 2024
1 parent 9655d6d commit 49467c0
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 49467c0

Please sign in to comment.