read

open override fun read(topic: String, partition: Int, from: Long): Flow<SourceMessage>

open override fun read(topic: String, partition: Int, from: Long, until: Long): Flow<SourceMessage>

Polls a consumer of its own until its position reaches until, so a partition ending in a gap completes too.