broker/ru.sydis.broker.implementations.streams/PartitionedSourceProcessor/PartitionedSourceProcessor

PartitionedSourceProcessor

constructor(brokerProps: Map<String, Any>, topic: String, pCount: Int = 1, pSplitter: String = "", keyClass: Class<K>, valClass: Class<V>, checkProcessing: ICheckProcessing = object : ICheckProcessing { override fun check(): Boolean { return true } })