RdKafka::Queue Class Reference

Queue interface. More...

#include <rdkafkacpp.h>

Static Public Member Functions
static Queue *	create (Handle *handle)
	Create Queue object.

Detailed Description

Queue interface.

Create a new message queue. Message queues allows the application to re-route consumed messages from multiple topic+partitions into one single queue point. This queue point, containing messages from a number of topic+partitions, may then be served by a single consume() method, rather than one per topic+partition combination.

See the RdKafka::Consumer::start(), RdKafka::Consumer::consume(), and RdKafka::Consumer::consume_callback() methods that take a queue as the first parameter for more information.

---

The documentation for this class was generated from the following file:

• src-cpp/rdkafkacpp.h