public StateQueryRequest<R> requireActive() {
        return new StateQueryRequest<>(
            storeName,
            position,
            partitions,
            query,
            executionInfoEnabled,
            true
        );
    }
Specifies that this query should only run on partitions for which this instance is the leader
(aka "active"). Partitions for which this instance is not the active replica will return
{@link FailureReason#NOT_ACTIVE}.
streams/src/main/java/org/apache/kafka/streams/query/StateQueryRequest.java