spi/me.ahoo.wow.spi.transport/PartitionedSource/read

read

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

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

The messages of partition from from to before until, then completes. By default the unbounded read up to the message at until - 1: a source whose partitions may end in a gap (such as transaction markers) overrides it.