@Override
    public void recordRestoration(final Time time, final long numRecords, final boolean initRemaining) {
        if (initRemaining) {
            throw new IllegalStateException("Standby task would not record remaining records to restore");
        }

        maybeRecordSensor(numRecords, time, updateSensor);
    }
@param id              the ID of this task
@param inputPartitions input topic partitions, used for thread metadata only
@param topology        the instance of {@link ProcessorTopology}
@param config          the {@link StreamsConfig} specified by the user
@param streamsMetrics  the {@link StreamsMetrics} created by the thread
@param stateMgr        the {@link ProcessorStateManager} for this task
@param stateDirectory  the {@link StateDirectory} created by the thread
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java