|
librdkafka
The Apache Kafka C/C++ client library
|
Consume callback class. More...
#include <rdkafkacpp.h>
Public Member Functions | |
| virtual void | consume_cb (Message &message, void *opaque)=0 |
The consume callback is used with RdKafka::Consumer::consume_callback() methods and will be called for each consumed message. More... | |
Consume callback class.
|
pure virtual |
The consume callback is used with RdKafka::Consumer::consume_callback() methods and will be called for each consumed message.
The callback interface is optional but provides increased performance.