#ifndef QKAFKAUTIL_H
#define QKAFKAUTIL_H

#include <QObject>

#include "librdkafka/include/rdkafkacpp.h"
#include "librdkafka/include/wingetopt.c"

class QKafkaUtil : public QObject
{
    Q_OBJECT
public:
    explicit QKafkaUtil(QObject *parent = nullptr);

    void setBrokers(QString brokers);
    void setTopic(QString topic);

    int initKafkaConf();

private:
    QString brokers;
    QString topic;

    std::string errStr;

    RdKafka::Conf * conf;

    RdKafka::Producer * producer = 0;
signals:

};

#endif // QKAFKAUTIL_H