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