Tail

interface Tail<out M>

One consumer's position in a partition, valid only for the duration of withTail.

Functions

Link copied to clipboard
abstract suspend fun poll(timeout: Duration): List<Log.Record<M>>

Waits up to timeout for at least one record, then returns it and any records already available. Returns empty only when this tail has reached the partition's tip and nothing arrived before timeout.