RebalanceCb Class Reference

Inheritance diagram for RebalanceCb:

Collaboration diagram for RebalanceCb:

Public Member Functions
void	rebalance_cb (RdKafka::KafkaConsumer *consumer, RdKafka::ErrorCode err, std::vector< RdKafka::TopicPartition *> &partitions) override

Static Private Member Functions
static void	part_list_print (const std::vector< RdKafka::TopicPartition *> &partitions)

Detailed Description

Definition at line 58 of file KafkaImporter.cpp.

Member Function Documentation

part_list_print()

static void RebalanceCb::part_list_print ( const std::vector< RdKafka::TopicPartition *> &  partitions )

inlinestaticprivate

Definition at line 60 of file KafkaImporter.cpp.

References logger::INFO, and LOG.

Referenced by rebalance_cb().

                                                                                   {
    for (unsigned int i = 0; i < partitions.size(); i++) {
      LOG(INFO) << "\t" << partitions[i]->topic() << "[" << partitions[i]->partition()
                << "]";
    }
  }

Here is the caller graph for this function:

rebalance_cb()

void RebalanceCb::rebalance_cb ( RdKafka::KafkaConsumer *  consumer, RdKafka::ErrorCode  err, std::vector< RdKafka::TopicPartition *> &  partitions  )

inlineoverride

Definition at line 68 of file KafkaImporter.cpp.

References eof_cnt, logger::INFO, LOG, part_list_print(), and partition_cnt.

                                                                            {
    LOG(INFO) << "RebalanceCb: " << RdKafka::err2str(err) << ": ";

    part_list_print(partitions);

    if (err == RdKafka::ERR__ASSIGN_PARTITIONS) {
      consumer->assign(partitions);
      partition_cnt = (int)partitions.size();
    } else {
      consumer->unassign();
      partition_cnt = 0;
    }
    eof_cnt = 0;
  }

Here is the call graph for this function:

---

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

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