Class CppKafkaProducer

• Defined in File CppKafkaProducer.h

Inheritance Relationships

Base Type

• public ska::pst::stat::StatKafkaProducer (Class StatKafkaProducer)

Class Documentation

class CppKafkaProducer : public ska::pst::stat::StatKafkaProducer

Implementation of the StatKafkaProducer interface that uses the CppKafka library.

Public Functions

CppKafkaProducer(const std::string &address)

Construct a new CppKafkaProducer.

Parameters

address – this is the broker address

virtual ~CppKafkaProducer() = default

Default destructor.

virtual void send(const std::string &topic, const std::string &payload) override

Send a message to a Kafka topic.

Parameters

• topic – the topic to send the message to

• payload – the message payload