Skip to content


StreamTask is a concrete AbstractTask.

Creating Instance

StreamTask takes the following to be created:

  • TaskId
  • Input TopicPartitions
  • ProcessorTopology
  • Main Consumer<byte[], byte[]>
  • StreamsConfig
  • StreamsMetricsImpl
  • StateDirectory
  • ThreadCache
  • Time
  • ProcessorStateManager
  • RecordCollector
  • InternalProcessorContext
  • LogContext

StreamTask is created when:

  • ActiveTaskCreator is requested to createActiveTask
  • TopologyTestDriver is requested to setupTask


Map<TopicPartition, OffsetAndMetadata> prepareCommit()


prepareCommit is part of the Task abstraction.

Back to top