redpanda 0.5.0

A crate for interacting with Redpanda Message Brokers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::array::TryFromSliceError;

pub use rdkafka::error::*;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum RedpandaError {
    #[error("Redpanda encountered a Kafka error")]
    Kafka(#[from] rdkafka::error::KafkaError),
    #[error("unknown Redpanda error")]
    Unknown,
}

#[derive(Error, Debug)]
pub enum RecordError {
    #[error("key doesn't deserialize to a DateTime<Utc>")]
    KeyDeserializeError(#[from] TryFromSliceError),
    #[error("unknown Record error")]
    Unknown,
}