rd_kafka_consume_start_queue

@brief Same as rd_kafka_consume_start() but re-routes incoming messages to the provided queue \p rkqu (which must have been previously allocated with rd_kafka_queue_new().

The application must use one of the rd_kafka_consume_*_queue() functions to receive fetched messages.

rd_kafka_consume_start_queue() must not be called multiple times for the same topic and partition without stopping consumption first with rd_kafka_consume_stop(). rd_kafka_consume_start() and rd_kafka_consume_start_queue() must not be combined for the same topic and partition.

extern (C) nothrow @nogc
int
rd_kafka_consume_start_queue

Meta