Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
svroonland committed Jan 2, 2025
1 parent 98de633 commit 901a536
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala
Original file line number Diff line number Diff line change
Expand Up @@ -611,6 +611,7 @@ private[consumer] final class ConsumerLive private[consumer] (

override def registerOffsetsCommittedInTransaction(
offsetBatch: OffsetBatch
): Task[Unit] = runloopAccess.withRunloopZIO(true)(runloop => runloop.registerOffsetsCommittedInTransaction(offsetBatch))
): Task[Unit] =
runloopAccess.withRunloopZIO(true)(runloop => runloop.registerOffsetsCommittedInTransaction(offsetBatch))

}

0 comments on commit 901a536

Please sign in to comment.