#include "kafka_config.h"

KafkaConfig* KafkaConfig::getIns() {
    static KafkaConfig kafkaConfig;
    return &kafkaConfig;
}

KafkaConfig::KafkaConfig() = default;

void KafkaConfig::load(QSettings *configs) {
    if(configs->value("consumer.servers").isValid()){
        _consumerServers = configs->value("consumer.servers").toStringList();
    }
    if(configs->value("consumer.topics").isValid()){
        _consumerTopics = configs->value("consumer.topics").toStringList();
    }
    if(configs->value("producer.servers").isValid()){
        _producerServers = configs->value("producer.servers").toStringList();
    }
}

QStringList KafkaConfig::getConsumerServers() const {
    return _consumerServers;
}

QStringList KafkaConfig::getConsumerTopics() const {
    return _consumerTopics;
}

QStringList KafkaConfig::getProducerServers() const {
    return _producerServers;
}

KafkaConfig::~KafkaConfig() = default;