Long endOffset() {
            return restoreEndOffset;
        }
ChangelogReader is created and maintained by the stream thread and used for both updating standby tasks and
restoring active tasks. It manages the restore consumer, including its assigned partitions, when to pause / resume
these partitions, etc.
<p>
The reader also maintains the source of truth for restoration state: only active tasks restoring changelog could
be completed, while standby tasks updating changelog would always be in restoring state after being initialized.
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java