rd_kafka_position

@brief Retrieve current positions (offsets) for topics+partitions.

The \p offset field of each requested partition will be set to the offset of the last consumed message + 1, or RD_KAFKA_OFFSET_INVALID in case there was no previous message.

@returns RD_KAFKA_RESP_ERR_NO_ERROR on success in which case the \p offset or \p err field of each \p partitions' element is filled in with the stored offset, or a partition specific error. Else returns an error code.

extern (C) nothrow @nogc
rd_kafka_position

Meta