diff --git a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java
index 79d24830788..f4f22b0e363 100644
--- a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java
+++ b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java
@@ -62,12 +62,12 @@ public interface CoordinatorPlayback<U> {
      *
      * @param offset the offset of the last record in the batch plus one.
      */
-    void updateLastWrittenOffset(Long offset);
+    void updateLastWrittenOffset(long offset);
 
     /**
      * Called when the high watermark advances.
      *
      * @param offset The offset of the new high watermark.
      */
-    void updateLastCommittedOffset(Long offset);
+    void updateLastCommittedOffset(long offset);
 }
diff --git a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
index 3aa622cc98b..f15da57cc34 100644
--- a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
+++ b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
@@ -138,7 +138,7 @@ public class SnapshottableCoordinator<S extends CoordinatorShard<U>, U> implemen
      * @param offset The new last written offset.
      */
     @Override
-    public synchronized void updateLastWrittenOffset(Long offset) {
+    public synchronized void updateLastWrittenOffset(long offset) {
         if (offset <= lastWrittenOffset) {
             throw new IllegalStateException("New last written offset " + offset + " of " + tp +
                 " must be greater than " + lastWrittenOffset + ".");
@@ -157,7 +157,7 @@ public class SnapshottableCoordinator<S extends CoordinatorShard<U>, U> implemen
      * @param offset The new last committed offset.
      */
     @Override
-    public synchronized void updateLastCommittedOffset(Long offset) {
+    public synchronized void updateLastCommittedOffset(long offset) {
         if (offset < lastCommittedOffset) {
             throw new IllegalStateException("New committed offset " + offset + " of " + tp +
                 " must be greater than or equal to " + lastCommittedOffset + ".");