Consumer.seek

Seek consumer for topic+partition to \p offset which is either an absolute or logical offset.

If \p timeout_ms is not 0 the call will wait this long for the seek to be performed. If the timeout is reached the internal state will be unknown and this function returns timed_out. If \p timeout_ms is 0 it will initiate the seek but return immediately without any error reporting (e.g., async).

This call triggers a fetch queue barrier flush.

an ErrorCode to indicate success or failure.

class Consumer
nothrow @nogc static
seek
(
Topic topic
,,
long offset
,)

Meta