OmniSciDB  ba1bac9284
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros 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 249 of file KafkaImporter.cpp.

Member Function Documentation

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

Definition at line 251 of file KafkaImporter.cpp.

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

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