BaseSourceProcessor

class BaseSourceProcessor<K : Any, V : Any>(brokerProps: Map<String, Any>, topic: String, keyClass: Class<K>, valClass: Class<V>) : SourceProcessor<K, V>

Constructors

constructor(brokerProps: Map<String, Any>, topic: String, keyClass: Class<K>, valClass: Class<V>)

open override fun getPartitionCount(): Int

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

open override fun startReporting(reportPeriodMs: Long)

open override fun stopReporting()

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

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

open override fun unsubscribe()

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