void restoreBatch(final Collection<ConsumerRecord<byte[], byte[]>> records) {
        synchronized (position) {
            try (final WriteBatch batch = new WriteBatch()) {
                for (final ConsumerRecord<byte[], byte[]> record : records) {
                    ChangelogRecordDeserializationHelper.applyChecksAndUpdatePosition(
                        record,
                        consistencyEnabled,
                        position
                    );
                    // If version headers are not present or version is V0
                    cfAccessor.addToBatch(record.key(), record.value(), batch);
                }
                write(batch);
            } catch (final RocksDBException e) {
                throw new ProcessorStateException("Error restoring batch to store " + name, e);
            }
        }
    }
Deletes keys entries in the range ['from', 'to'], including 'from' and excluding 'to'.
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java