Skip to content

Commit

Permalink
fmt code
Browse files Browse the repository at this point in the history
  • Loading branch information
flavienbert committed Oct 27, 2023
1 parent 76ed412 commit 83a75fb
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ private final case class OffsetBatchImpl(
otherOffsets.offsets.foreach { case (tp, offset) =>
val laterOffset = offsets.get(tp) match {
case Some(existing) => if (existing.offset < offset.offset) offset else existing
case None => offset
case None => offset
}
newOffsets += tp -> laterOffset
}
Expand Down

0 comments on commit 83a75fb

Please sign in to comment.