OmniSciDB  95562058bd
 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 248 of file KafkaImporter.cpp.

Member Function Documentation

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

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: