KafkaStream.hpp

Go to the documentation of this file.

 
#ifndef ERSES_KAFKASTREAM_HPP
#define ERSES_KAFKASTREAM_HPP
 
#include <ers/OutputStream.hpp>
#include <librdkafka/rdkafkacpp.h>
#include <nlohmann/json.hpp>
#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