Forgot to commit this file

zio · Nov 2, 2024 · 90ca347 · 90ca347
1 parent 3c0cfd1
commit 90ca347
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala
@@ -69,6 +69,8 @@ final class PartitionStreamControl private (
 
   def queueSize: UIO[Int] = queueInfoRef.get.map(_.size)
 
+  def lastPulledOffset: UIO[Option[Offset]] = queueInfoRef.get.map(_.lastPulledOffset)
+
   /**
    * @return
    *   the number of polls there are records idling in the queue. It is increased on every poll (when the queue is