Method KafkaTopicSelector

Server/src/kafka/KafkaTopicSelector.cpp:23–38

/ * Constructor for class * * \param [in] logPtr Pointer to Logger instance * \param [in] cfg Pointer to the config instance * \param [in] producer Pointer to the kafka producer ***********************************************************************/

 * \param [in] producer Pointer to the kafka producer
 ***********************************************************************/
KafkaTopicSelector::KafkaTopicSelector(Logger *logPtr, Config *cfg,  RdKafka::Producer *producer) {
    logger = logPtr;
    this->cfg = cfg;

    if (cfg->debug_msgbus)
        debug = true;
    else
        debug = false;


    this->producer = producer;

    peer_partitioner_callback = new KafkaPeerPartitionerCallback();
    tconf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC);

}

/*********************************************************************//**
 * Destructor for class