OmniSciDB
0264ff685a
|
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) |
Definition at line 57 of file KafkaImporter.cpp.
|
inlinestaticprivate |
Definition at line 59 of file KafkaImporter.cpp.
References logger::INFO, and LOG.
Referenced by rebalance_cb().
|
inlineoverride |
Definition at line 67 of file KafkaImporter.cpp.
References eof_cnt, logger::INFO, LOG, part_list_print(), and partition_cnt.