recordQueue

@Singleton
@Named(value = "recordQueue")
fun recordQueue(@Named(value = "numInputPartitions") numInputPartitions: Int): PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>

A queue for records uploading.