process

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