process

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