The Apache Kafka C/C++ client library
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
RdKafka::Queue Class Reference

Queue interface. More...

#include <rdkafkacpp.h>

Static Public Member Functions

static Queuecreate (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: