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...

Detailed Description

Consume callback class.

Member Function Documentation

virtual void RdKafka::ConsumeCb::consume_cb	(	Message &	message,
		void *	opaque
	)

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.

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