rd_kafka_seek

@brief 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 RD_KAFKA_RESP_ERR__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.

@returns RD_KAFKA_RESP_ERR__NO_ERROR on success else an error code.

extern (C) nothrow @nogc
rd_kafka_seek

Meta