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.

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

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/ImportExport/KafkaImporter.cpp