broker/ru.sydis.broker.interfaces.streams/SourceProcessor

SourceProcessor

interface SourceProcessor<K, V>

Интерфейс для Source-процессора. Отвечает за подписку на источник данных и передачу сообщений в пайплайн обработки.

Inheritors

Functions

Link copied to clipboard
abstract fun getPartitionCount(): Int

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

Link copied to clipboard
abstract fun startReporting(reportPeriodMs: Long = 10000)
Link copied to clipboard
abstract fun stopReporting()
Link copied to clipboard
abstract fun subscribe(callback: (p: Int, K?, V, ts: Long) -> Unit)

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

Link copied to clipboard
abstract fun unsubscribe()

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