EventCb Class Reference

Inheritance diagram for EventCb:

Collaboration diagram for EventCb:

Public Member Functions
void	event_cb (RdKafka::Event &event) override

Detailed Description

Definition at line 256 of file KafkaImporter.cpp.

Member Function Documentation

void EventCb::event_cb ( RdKafka::Event &  event )

inlineoverride

Definition at line 258 of file KafkaImporter.cpp.

References logger::ERROR, logger::INFO, LOG, run, and VLOG.

                                              {
    switch (event.type()) {
      case RdKafka::Event::EVENT_ERROR:
        LOG(ERROR) << "ERROR (" << RdKafka::err2str(event.err()) << "): " << event.str();
        if (event.err() == RdKafka::ERR__ALL_BROKERS_DOWN) {
          LOG(ERROR) << "All brokers are down, we may need special handling here";
          run = false;
        }
        break;

      case RdKafka::Event::EVENT_STATS:
        VLOG(2) << "\"STATS\": " << event.str();
        break;

      case RdKafka::Event::EVENT_LOG:
        LOG(INFO) << "LOG-" << event.severity() << "-" << event.fac().c_str() << ":"
                  << event.str().c_str();
        break;

      case RdKafka::Event::EVENT_THROTTLE:
        LOG(INFO) << "THROTTLED: " << event.throttle_time() << "ms by "
                  << event.broker_name() << " id " << (int)event.broker_id();
        break;

      default:
        LOG(INFO) << "EVENT " << event.type() << " (" << RdKafka::err2str(event.err())
                  << "): " << event.str();
        break;
    }
  }

---

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

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