process

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