autumn-plugin-kafka 0.3.0

Kafka producer and consumer plugin for autumn-web applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Error type for the crate.

/// An error from the Kafka plugin.
#[derive(Debug, thiserror::Error)]
#[non_exhaustive]
pub enum KafkaError {
    /// The configuration is not valid.
    #[error("invalid Kafka config: {0}")]
    Config(String),
    /// The Kafka client returned an error.
    #[error("Kafka client error: {0}")]
    Client(String),
    /// JSON encode or decode failed.
    #[error("Kafka JSON error: {0}")]
    Json(#[from] serde_json::Error),
    /// The operation did not complete in time.
    #[error("Kafka operation timed out")]
    Timeout,
    /// The broker rejected the request. A retry does not help.
    ///
    /// Examples: the record is too large, or the client has no permission.
    #[error("Kafka rejected the request: {0}")]
    Rejected(String),
    /// The broker or the plugin is not available.
    #[error("Kafka is not available: {0}")]
    Unavailable(String),
}