Class RebalanceCb¶

class RebalanceCb : public RebalanceCb ¶

Public Functions

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

Private Static Functions

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