[greyhound] gaps limit calculation script (#35898)

[greyhound] gaps limit calculation script #automerge GitOrigin-RevId: 75a060f20589036570bad2077d3e906fa8db9bcd
wix · Sep 8, 2023 · 6816186 · 6816186
1 parent 21b10ea
commit 6816186
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/OffsetsAndGaps.scala b/core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/OffsetsAndGaps.scala
@@ -167,6 +167,8 @@ case class OffsetAndGaps(offset: Offset, gaps: Seq[Gap], committable: Boolean =
     val plainGapsString = s"${offset.toString}${LAST_HANDLED_OFFSET_SEPARATOR}${gaps.sortBy(_.start).mkString(GAPS_STRING_SEPARATOR)}"
     Base64.getEncoder.encodeToString(GzipCompression.compress(plainGapsString.getBytes()))
   }
+
+  def plainGapsString: String = s"${offset.toString}${LAST_HANDLED_OFFSET_SEPARATOR}${gaps.sortBy(_.start).mkString(GAPS_STRING_SEPARATOR)}"
 }
 
 object OffsetAndGaps {