Skip to content

ActiveTaskCreator

createTasks

Collection<Task> createTasks(
  Consumer<byte[], byte[]> consumer,
  Map<TaskId, Set<TopicPartition>> tasksToBeCreated)

createTasks...FIXME

createTasks is used when:

createActiveTaskFromStandby

StreamTask createActiveTaskFromStandby(
  StandbyTask standbyTask,
  Set<TopicPartition> inputPartitions,
  Consumer<byte[], byte[]> consumer)

createActiveTaskFromStandby...FIXME

createActiveTaskFromStandby is used when:

createActiveTask

StreamTask createActiveTask(
  TaskId taskId,
  Set<TopicPartition> inputPartitions,
  Consumer<byte[], byte[]> consumer,
  LogContext logContext,
  ProcessorTopology topology,
  ProcessorStateManager stateManager,
  InternalProcessorContext context)

createActiveTask...FIXME

createActiveTask is used when:

Back to top