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.