This is a follow-up task to #122. Most probably we need to add similar metrics as for subscribe with `RebalanceListener` ``` def subscribe(topics: Nes[Topic], listener: Option[RebalanceListener[F]]) = { val listener1 = listener.map(rebalanceListener) for { _ <- count("subscribe", topics.toList) r <- self.subscribe(topics, listener1) } yield r } ``` https://github.com/evolution-gaming/skafka/blob/b76b257d5f6b2c75564b2bceae5d147d11db424d/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala#L639
This is a follow-up task to #122.
Most probably we need to add similar metrics as for subscribe with
RebalanceListenerskafka/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala
Line 639 in b76b257