InputConsumerTask
constructor(inputFlow: ReservingDeserializingInputFlow, pipelineInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partitioner: InputPartitioner, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter)