Fix timeToDeadlineMillis

zio · Nov 10, 2024 · d3e0270 · d3e0270
1 parent 7994954
commit d3e0270
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -106,7 +106,7 @@ private[consumer] final class Runloop private (
     ): Task[Unit] = {
       val deadline = java.lang.System.nanoTime() + maxRebalanceDuration.toNanos - commitTimeoutNanos
 
-      def timeToDeadlineMillis(): Long = (java.lang.System.nanoTime() - deadline) / 1000000L
+      def timeToDeadlineMillis(): Long = (deadline - java.lang.System.nanoTime()) / 1000000L
 
       val endingTps = streamsToEnd.map(_.tp).toSet