diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala index 5dc1ffac6..13e729391 100644 --- a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala +++ b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala @@ -203,7 +203,7 @@ private[consumer] final class Runloop private ( onAssigned = (assignedTps, _) => for { rebalanceEvent <- lastRebalanceEvent.get - _ <- ZIO.logInfo { + _ <- ZIO.logDebug { val sameRebalance = if (rebalanceEvent.wasInvoked) " in same rebalance" else "" s"${assignedTps.size} partitions are assigned$sameRebalance" } @@ -217,7 +217,7 @@ private[consumer] final class Runloop private ( onRevoked = (revokedTps, _) => for { rebalanceEvent <- lastRebalanceEvent.get - _ <- ZIO.logInfo { + _ <- ZIO.logDebug { val sameRebalance = if (rebalanceEvent.wasInvoked) " in same rebalance" else "" s"${revokedTps.size} partitions are revoked$sameRebalance" }