KafkaException.h

#pragma once
 
#include <kafka/Project.h>
 
#include <kafka/Error.h>
#include <kafka/RdKafkaHelper.h>
#include <kafka/Utility.h>
 
#include <librdkafka/rdkafka.h>
 
#include <chrono>
#include <exception>
#include <string>
 
 
namespace KAFKA_API {
 
class KafkaException: public std::exception
{
public:
    KafkaException(const char* filename, std::size_t lineno, const Error& error)
        : _when(std::chrono::system_clock::now()),
          _filename(filename),
          _lineno(lineno),
          _error(std::make_shared<Error>(error))
    {}
 
    const Error& error() const { return *_error; }
 
    const char* what() const noexcept override
    {
        _what = utility::getLocalTimeString(_when) + ": " + _error->toString() + " (" + std::string(_filename) + ":" + std::to_string(_lineno) + ")";
        return _what.c_str();
    }
 
private:
    using TimePoint = std::chrono::system_clock::time_point;
 
    const   TimePoint               _when;
    const   std::string             _filename;
    const   std::size_t             _lineno;
    const   std::shared_ptr<Error>  _error;
    mutable std::string             _what;
};
 
 
#define KAFKA_THROW_ERROR(error)          throw KafkaException(__FILE__, __LINE__, error)
#define KAFKA_THROW_IF_WITH_ERROR(error)  if (error) KAFKA_THROW_ERROR(error)
 
} // end of KAFKA_API