def METHOD_NAME(self, store: StoreT, tp: TP, offset: int) -> None:
    """Mark the persisted offset for a TP to be saved on commit.
    This is used for "exactly_once" processing guarantee.
    Instead of writing the persisted offset to RocksDB when the message
    is sent, we write it to disk when the offset is committed.
    """
    existing_entry = self._pending_persisted_offsets.get(tp)
    if existing_entry is not None:
        _, existing_offset = existing_entry
        if offset < existing_offset:
            return
    self._pending_persisted_offsets[tp] = (store, offset)