crabka-client-streams 0.3.2

KIP-1071 Kafka Streams rebalance-protocol client for Apache Kafka in Rust
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
28
29
30
31
32
33
34
35
36

//! Error type for the streams membership client.

/// Errors surfaced by the streams membership client.
#[derive(Debug, thiserror::Error)]
pub enum StreamsClientError {
    /// Transport / dispatch failure from `crabka-client-core`.
    #[error(transparent)]
    Transport(#[from] crabka_client_core::ClientError),
    /// Building the topology failed (bad node graph).
    #[error("topology error: {0}")]
    Topology(#[from] crate::topology::TopologyError),
    /// The group coordinator was unavailable past the retry deadline.
    #[error("streams group coordinator unavailable")]
    CoordinatorUnavailable,
    /// The broker rejected the topology (`STREAMS_INVALID_TOPOLOGY*` family).
    #[error("invalid topology (code {code}): {message}")]
    InvalidTopology { code: i16, message: String },
    /// `GROUP_AUTHORIZATION_FAILED` / `TOPIC_AUTHORIZATION_FAILED`.
    #[error("authorization failed (code {0})")]
    Authorization(i16),
    /// `GROUP_ID_NOT_FOUND`.
    #[error("group id not found")]
    GroupIdNotFound,
    /// The membership handle has been closed.
    #[error("membership closed")]
    Closed,
    /// An unmapped broker error code.
    #[error("broker error code {0}")]
    Server(i16),
    /// A runtime processing/produce/commit failure.
    #[error("runtime error: {0}")]
    Runtime(String),
    /// An interactive query failed.
    #[error(transparent)]
    InteractiveQuery(#[from] crate::runtime::iq::IqError),
}