broker/ru.sydis.broker.implementations.streams/LoggingProcessor

LoggingProcessor

class LoggingProcessor<K, V> : Processor<K, V>

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun process(rec: StreamRecord<K?, V>): StreamRecord<K?, V>?