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

PartitionedSourceProcessor

open class PartitionedSourceProcessor<K : Any, V : Any>(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 } }) : SourceProcessor<K, V>

Constructors

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 } })

Functions

getPartitionCount

open override fun getPartitionCount(): Int

Получение количества партицций из процессора

startReporting

open override fun startReporting(reportPeriodMs: Long)

stopReporting

open override fun stopReporting()

open override fun subscribe(callback: (p: Int, K?, V, Long) -> Unit)

Подписка на источник данных.

unsubscribe

open override fun unsubscribe()

Остановка подписки на источник данных. Вызывается при завершении работы пайплайна.