Skip to content


AbstractTask is a base abstraction of the Task abstraction for tasks.


Creating Instance

AbstractTask takes the following to be created:

Abstract Class

AbstractTask is an abstract class and cannot be created directly. It is created indirectly for the concrete AbstractTasks.

Input Partitions

AbstractTask is given a set of input TopicPartitions to consume and process records from when created and later when updateInputPartitions.

Back to top