kafkaesque 0.0.15

Kafka implementations in Rust (Unofficial)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

mod api_keys;
mod codec;
mod crc32;
mod error_code;
mod errors;
mod fixed_lengths;
mod request;
mod variable_lengths;

pub mod api;

pub use api_keys::ApiKey;
pub use codec::{FixedLength, Read, Write};
pub use error_code::ErrorCode;
pub use errors::{FormatError, Result};
pub use request::{ApiVersion, CorrelationId, RequestHeader, RequestMessage};
pub use variable_lengths::{NullableString, VarInt, VarIntArray, VarIntString};

/// Default TCP buffer size for [BrokerConnection] in bytes
pub static DEFAULT_BUF_SIZE: usize = 8 * 1024;