ByStreamInputPartitioner

@Singleton

@Secondary

The default input partitioner, which partitions by the stream name. TODO: Should be round-robin?

Constructors

constructor()

open override fun getPartition(record: DestinationRecordRaw, numParts: Int): Int