@Override
        public void run() {
            releaseAcquisitionLockOnTimeout(memberId, firstOffset, lastOffset);
        }
The task is executed when the acquisition lock timeout is reached. The task releases the acquired records.
core/src/main/java/kafka/server/share/SharePartition.java