private void maybeResetFetchDeadline() {
        boolean reset = mainConsumerInstanceIdFuture.isDone()
            && (!stateUpdaterEnabled && restoreConsumerInstanceIdFuture.isDone());

        if (processingMode.equals(StreamsConfigUtils.ProcessingMode.EXACTLY_ONCE_ALPHA)) {
            throw new UnsupportedOperationException("not implemented yet");
        } else if (!threadProducerInstanceIdFuture.isDone()) {
            reset = false;
        }

        if (reset) {
            fetchDeadlineClientInstanceId = -1L;
        }
    }
Main event loop for polling, and processing records through topologies.

@throws IllegalStateException If store gets registered after initialized is already finished
@throws StreamsException      if the store's change log does not contain the partition
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java