diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractColumnFamilyAccessor.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractColumnFamilyAccessor.java
index 0288872f567d4..a7c7ab0df63dd 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractColumnFamilyAccessor.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractColumnFamilyAccessor.java
@@ -69,8 +69,6 @@ public final void commit(final RocksDBStore.DBAccessor accessor, final Map<Topic
                 }
             }
         }
-        // We need to remove this flush call when implementing KAFKA-19712
-        this.flush(accessor, offsetColumnFamilyHandle);
     }
 
     @Override
@@ -112,15 +110,6 @@ public final Long getCommittedOffset(final RocksDBStore.DBAccessor accessor, fin
         return null;
     }
 
-    /**
-     * Invokes commit in the underlying ColumnFamilyAccessor.
-     * Subclasses should implement this method to define specific commit behavior.
-     * This method will be removed when implementing KAFKA-19712
-     *
-     * @param accessor the RocksDB accessor used to interact with the database
-     * @throws RocksDBException if an error occurs during the commit operation
-     */
-    protected abstract void flush(final RocksDBStore.DBAccessor accessor, final ColumnFamilyHandle offsetColumnFamilyHandle) throws RocksDBException;
 
     private void wipeOffsets(final RocksDBStore.DBAccessor accessor) throws RocksDBException {
         try (final RocksIterator iter = accessor.newIterator(offsetColumnFamilyHandle)) {
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessor.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessor.java
index db4274cc62582..70a19ff125fa2 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessor.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessor.java
@@ -239,11 +239,6 @@ public long approximateNumEntries(final DBAccessor accessor)
                 + accessor.approximateNumEntries(newColumnFamily);
     }
 
-    @Override
-    public void flush(final DBAccessor accessor, final ColumnFamilyHandle offsetColumnFamilyHandle) throws RocksDBException {
-        accessor.flush(oldColumnFamily, newColumnFamily, offsetColumnFamilyHandle);
-    }
-
     @Override
     public void addToBatch(final byte[] key,
                            final byte[] value,
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
index 621e1eaa5661b..7b616eb6b88a7 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
@@ -1115,11 +1115,6 @@ public long approximateNumEntries(final DBAccessor accessor) throws RocksDBExcep
             return accessor.approximateNumEntries(columnFamily);
         }
 
-        @Override
-        public void flush(final DBAccessor accessor, final ColumnFamilyHandle offsetColumnFamilyHandle) throws RocksDBException {
-            accessor.flush(columnFamily, offsetColumnFamilyHandle);
-        }
-
         @Override
         public void addToBatch(final byte[] key,
                                final byte[] value,
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessorTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessorTest.java
index 94efbb18a66c5..437352b5c9005 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessorTest.java
@@ -16,7 +16,6 @@
  */
 package org.apache.kafka.streams.state.internals;
 
-import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.utils.Bytes;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.errors.ProcessorStateException;
@@ -35,9 +34,7 @@
 
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 import java.util.function.Function;
 
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
@@ -341,16 +338,6 @@ public void shouldReturnSumOfEntriesFromBothColumnFamilies() throws RocksDBExcep
         assertEquals(150L, result);
     }
 
-    @Test
-    public void shouldFlushBothColumnFamiliesOnCommit() throws RocksDBException {
-        final Map<TopicPartition, Long> offsets = new HashMap<>();
-        offsets.put(new TopicPartition("topic", 0), 100L);
-
-        accessor.commit(dbAccessor, offsets);
-
-        verify(dbAccessor).flush(oldCF, newCF, offsetsCF);
-    }
-
     @Test
     public void shouldCreateRangeIterator() {
         final RocksIterator iterNewFormat = mock(RocksIterator.class);
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java
index 1a6a83848d782..128534a1bb878 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java
@@ -86,7 +86,6 @@
 import org.rocksdb.Statistics;
 
 import java.io.File;
-import java.io.IOException;
 import java.lang.reflect.Field;
 import java.math.BigInteger;
 import java.util.ArrayList;
@@ -918,16 +917,6 @@ public void shouldReturnValueOnRange() {
         }
     }
 
-    @Test
-    public void shouldThrowProcessorStateExceptionOnPutDeletedDir() throws IOException {
-        rocksDBStore.init(context, rocksDBStore);
-        Utils.delete(dir);
-        rocksDBStore.put(
-            new Bytes(stringSerializer.serialize(null, "anyKey")),
-            stringSerializer.serialize(null, "anyValue"));
-        assertThrows(ProcessorStateException.class, () -> rocksDBStore.commit(Map.of()));
-    }
-
     @Test
     public void shouldHandleToggleOfEnablingBloomFilters() {
         final Properties props = StreamsTestUtils.getStreamsConfig();