class StreamTask extends AbstractTask implements ProcessorNodePunctuator, Task {

    @Override
    public void maybeInitTaskTimeoutOrThrow(final long currentWallClockMs,
                                            final TimeoutException timeoutException) throws StreamsException {
        maybeInitTaskTimeoutOrThrow(currentWallClockMs, timeoutException, log);
    }

    public  StreamTask(final TaskId id,
                      final Set<TopicPartition> partitions,
                      final ProcessorTopology topology,
                      final Consumer<byte[], byte[]> mainConsumer,
                      final StreamsConfig config,
                      final StreamsMetricsImpl streamsMetrics,
                      final StateDirectory stateDirectory,
                      final ThreadCache cache,
                      final Time time,
                      final ProcessorStateManager stateMgr,
                      final RecordCollector recordCollector,
                      final InternalProcessorContext processorContext);

}