KafkaStream.hpp

Go to the documentation of this file.

 
#ifndef ERSES_KAFKASTREAM_HPP 
#define ERSES_KAFKASTREAM_HPP
 
#include <ers/OutputStream.hpp>
#include <nlohmann/json.hpp>
#include <librdkafka/rdkafkacpp.h>
#include <string>
#include <vector>
 
namespace erskafka
{    
    class KafkaStream : public ers::OutputStream
    {
      public:
          explicit KafkaStream( const std::string & param);
        void write( const ers::Issue & issue ) override;
        
      private:  
        std::string m_partition;
        RdKafka::Producer *m_producer;
        void ers_to_json(const ers::Issue & issue, size_t chain, std::vector<nlohmann::json> & j_objs);
        void kafka_exporter(std::string input, std::string topic);
 
    };
} //namespace erskafka
 
#endif