16 #ifndef ALICEO2_MONITORING_TRANSPORTS_KAFKA_H 17 #define ALICEO2_MONITORING_TRANSPORTS_KAFKA_H 21 #include <boost/array.hpp> 22 #include <boost/asio.hpp> 23 #include <boost/algorithm/string.hpp> 26 #include <librdkafka/rdkafkacpp.h> 45 Kafka(
const std::string& host,
unsigned int port,
const std::string& topic =
"test");
52 void send(std::string&& message)
override;
56 RdKafka::Producer* producer;
66 #endif // ALICEO2_MONITORING_TRANSPORTS_KAFKA_H
~Kafka()
Deletes producer.
Definition: Kafka.cxx:48
Transport interface for backends.
Definition: TransportInterface.h:31
Kafka(const std::string &host, unsigned int port, const std::string &topic="test")
Definition: Kafka.cxx:29
void send(std::string &&message) override
Definition: Kafka.cxx:53
Transport that sends string formatted metrics via Kafka.
Definition: Kafka.h:38