public long addAndGetOffset(long tmpOffset) {
        this.firstCreate = false;
        this.modified = true;
        this.lstUpdateTime.set(System.currentTimeMillis());
        return this.offset.addAndGet(tmpOffset - tmpOffset % DataStoreUtils.STORE_INDEX_HEAD_LEN);
    }
Initial offset storage information

@param topic          the topic name
@param brokerId       the broker id
@param partitionId    the partition id
@param lstRstTerm     the last reset term
@param offset         the offset
@param messageId      the message id
@param firstCreate    whether is the first record creation
@param lstUpdateTime  the last update time
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetStorageInfo.java