broker/ru.sydis.broker.implementations.streams/BaseSinkProcessor

BaseSinkProcessor

open class BaseSinkProcessor<K, V : Any>(broker: MessageBroker<K, V>, topic: String) : Processor<K, V>

Constructors

BaseSinkProcessor

constructor(broker: MessageBroker<K, V>, topic: String)

Functions

open override fun process(rec: StreamRecord<K?, V>): StreamRecord<K?, V>?

fun startReporting(sectorSize: Long)

fun stopReporting()