exceptions.hpp

#pragma once
 
#include <stdexcept>
 
USERVER_NAMESPACE_BEGIN
 
namespace kafka {
 
/// @brief Base exception thrown by Producer::Send and Producer::SendAsync
/// on send or delivery errors.
class SendException : public std::runtime_error {
public:
    using std::runtime_error::runtime_error;
 
    /// @brief Returns whether it makes sense to retry failed send.
    ///
    /// @see
    /// https://docs.confluent.io/platform/current/clients/librdkafka/html/md_INTRODUCTION.html#autotoc_md8
    bool IsRetryable() const noexcept;
 
protected:
    SendException(const char* what, bool is_retryable);
 
private:
    const bool is_retryable_{false};
};
 
class DeliveryTimeoutException final : public SendException {
    static constexpr const char* kWhat{
        "Message is not delivered after `delivery_timeout` milliseconds. Hint: "
        "Adjust `delivery_timeout` and `queue_buffering_*` options or manually "
        "retry the send request."};
 
public:
    DeliveryTimeoutException();
};
 
class QueueFullException final : public SendException {
    static constexpr const char* kWhat{
        "The sending queue is full - send request cannot be scheduled. Hint: "
        "Manually retry the error or increase `queue_buffering_max_messages` "
        "and/or `queue_buffering_max_kbytes` config option."};
 
public:
    QueueFullException();
};
 
class MessageTooLargeException final : public SendException {
    static constexpr const char* kWhat{
        "Message size exceeds configured limit. Hint: increase "
        "`message_max_bytes` config option."};
 
public:
    MessageTooLargeException();
};
 
class UnknownTopicException final : public SendException {
    static constexpr const char* kWhat{"Given topic does not exist in cluster."};
 
public:
    UnknownTopicException();
};
 
class UnknownPartitionException final : public SendException {
    static constexpr const char* kWhat = "Topic does not have given partition.";
 
public:
    UnknownPartitionException();
};
 
}  // namespace kafka
 
USERVER_NAMESPACE_END