OmniSciDB  c1a53651b2
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
ConsumeCb Class Reference
+ Inheritance diagram for ConsumeCb:
+ Collaboration diagram for ConsumeCb:

Public Member Functions

void consume_cb (RdKafka::Message &msg, void *opaque) override

Detailed Description

Definition at line 248 of file KafkaImporter.cpp.

Member Function Documentation

void ConsumeCb::consume_cb ( RdKafka::Message &  msg,
void *  opaque 

Definition at line 250 of file KafkaImporter.cpp.

250  {
251  // reinterpret_cast<KafkaMgr*>(opaque)->
252  // msg_consume(&msg, opaque);
253  }

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