Reduce diff

zio · Nov 26, 2024 · 208cd46 · 208cd46
1 parent 7050acc
commit 208cd46
Showing 1 changed file with 13 additions and 13 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala
@@ -67,6 +67,19 @@ private[consumer] final class LiveCommitter(
          }
   } yield ()
 
+  private def mergeCommitOffsets(commits: Chunk[Commit]): Map[TopicPartition, OffsetAndMetadata] =
+    commits
+      .foldLeft(mutable.Map.empty[TopicPartition, OffsetAndMetadata]) { case (acc, commit) =>
+        commit.offsets.foreach { case (tp, offset) =>
+          acc += (tp -> acc
+            .get(tp)
+            .map(current => if (current.offset() > offset.offset()) current else offset)
+            .getOrElse(offset))
+        }
+        acc
+      }
+      .toMap
+
   private def handleCommitCompletion(
     commits: Chunk[Commit],
     offsets: Map[TopicPartition, OffsetAndMetadata],
@@ -100,19 +113,6 @@ private[consumer] final class LiveCommitter(
       }
       .unit
 
-  private def mergeCommitOffsets(commits: Chunk[Commit]): Map[TopicPartition, OffsetAndMetadata] =
-    commits
-      .foldLeft(mutable.Map.empty[TopicPartition, OffsetAndMetadata]) { case (acc, commit) =>
-        commit.offsets.foreach { case (tp, offset) =>
-          acc += (tp -> acc
-            .get(tp)
-            .map(current => if (current.offset() > offset.offset()) current else offset)
-            .getOrElse(offset))
-        }
-        acc
-      }
-      .toMap
-
   /**
    * Wrapper that converts KafkaConsumer#commitAsync to ZIO
    *