1#![doc = include_str!("../README.md")]
2
3mod api;
4
5mod admin;
6mod consumer;
7mod core;
8mod metadata;
9mod network;
10mod producer;
11
12pub(crate) use self::core::constants;
13pub use self::core::{config, error, types};
14
15pub use admin::{
16 AlterConfigOp, AlterConfigOpType, BrokerDescription, BrokerFeatureLevel, ClusterDescription,
17 ConfigEntry, ConfigResource, ConfigResourceConfig, ConfigResourceType,
18 ConsumerGroupDescription, ConsumerGroupListing, ConsumerGroupMemberDescription, FeatureUpdate,
19 FeatureUpgradeType, GroupDescription, GroupListing, GroupMemberDescription, KafkaAdmin,
20 NewPartitions, NewTopic, TopicDescription, TopicListing, TopicPartitionDescription,
21};
22pub use api::{KafkaClient, KafkaTopic};
23pub use config::{
24 AdminConfig, AutoOffsetReset, ClientConfig, ConsumerConfig, IsolationLevel,
25 ProducerCompression, ProducerConfig, ProducerPartitioner, SaslConfig, SaslMechanism,
26 SecurityProtocol, TlsConfig,
27};
28pub use consumer::{
29 AcknowledgeType, AcknowledgementCommitCallback, KafkaConsumer, KafkaShareConsumer,
30 ShareAcknowledgementCommit, ShareAcquireMode, ShareConsumerOptions, ShareRecord, ShareRecords,
31};
32pub use error::{
33 AdminError, ConsumerError, ConsumerGroupMetadataError, Error, ProducerError, Result,
34 TransactionStateError,
35};
36pub use network::{ConnectedTcpStream, TcpConnector, TokioTcpConnector};
37pub use producer::KafkaProducer;
38pub use tokio_util::sync::CancellationToken;
39pub use types::{
40 CommitOffset, ConsumerGroupMetadata, ConsumerRebalanceEvent, ConsumerRebalanceListener,
41 ConsumerRecord, ConsumerRecords, KafkaMessage, OffsetAndTimestamp, ProduceAck, ProduceRecord,
42 RecordHeader, SubscriptionPattern, TopicPartition, TopicPartitionInfo, TopicPartitionKey,
43 TopicPartitionOffset, TopicPartitionOffsetAndTimestamp, TopicPartitionTimestamp,
44};