consume

open override fun consume(partition: Int): Flow<T>