kafka_rs/
lib.rs

1#![allow(clippy::single_match)] // Single-match is great for future-proofing code.
2
3mod broker;
4pub mod client;
5mod clitask;
6mod codec;
7pub mod error;
8#[cfg(feature = "internal")]
9pub mod internal;
10
11pub use kafka_protocol;
12pub use kafka_protocol::indexmap;
13
14pub use client::{Acks, Client, ListOffsetsPosition, Message, TopicProducer};
15pub use kafka_protocol::indexmap::IndexMap;
16pub use kafka_protocol::protocol::StrBytes;
17pub use kafka_protocol::records::{Compression, Record};
18
19#[cfg(feature = "internal")]
20pub use internal::InternalClient;
21
22/* TODO:
23- look into using the multishot crate throughout, instead of lots of oneshot allocations or unwieldy unbounded_mpsc.
24*/