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, KafkaAdmin,
19 NewPartitions, NewTopic, TopicDescription, TopicListing, TopicPartitionDescription,
20};
21pub use api::{KafkaClient, KafkaTopic};
22pub use config::{
23 AdminConfig, AutoOffsetReset, ClientConfig, ConsumerConfig, IsolationLevel,
24 ProducerCompression, ProducerConfig, ProducerPartitioner, SaslConfig, SaslMechanism,
25 SecurityProtocol, TlsConfig,
26};
27pub use consumer::{
28 AcknowledgeType, AcknowledgementCommitCallback, KafkaConsumer, KafkaShareConsumer,
29 ShareAcknowledgementCommit, ShareAcquireMode, ShareConsumerOptions, ShareRecord, ShareRecords,
30};
31pub use error::{
32 AdminError, ConsumerError, ConsumerGroupMetadataError, Error, ProducerError, Result,
33 TransactionStateError,
34};
35pub use producer::KafkaProducer;
36pub use types::{
37 CommitOffset, ConsumerGroupMetadata, ConsumerRecord, ConsumerRecords, KafkaMessage,
38 OffsetAndTimestamp, ProduceAck, ProduceRecord, RecordHeader, SubscriptionPattern,
39 TopicPartition, TopicPartitionInfo, TopicPartitionKey, TopicPartitionOffset,
40 TopicPartitionOffsetAndTimestamp, TopicPartitionTimestamp,
41};