Function rd_kafka_queue_forward

pub unsafe extern "C" fn rd_kafka_queue_forward(
    src: *mut rd_kafka_queue_t,
    dst: *mut rd_kafka_queue_t,
)

Expand description

Forward/re-route queue \p src to \p dst. If dst is NULL the forwarding is removed.

The internal refcounts for both queues are increased.

@remark Regardless of whether dst is NULL or not, after calling this function, src will not forward it’s fetch queue to the consumer queue.

Function rd_kafka_queue_forwardCopy item path