1#![allow(clippy::single_match)] mod 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