Revert to logDebug

zio · Dec 22, 2023 · 2714a23 · 2714a23
1 parent ef19ec2
commit 2714a23
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -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"
                }