HeartbeatTask

constructor(config: DestinationConfiguration, outputQueue: PartitionedQueue<PipelineInputEvent>, checkpointManager: CheckpointManager)