ruststream_rdkafka/
lib.rs

1#![doc = include_str!("README.md")]
2#![forbid(unsafe_code)]
3
4mod attention;
5#[cfg(feature = "asyncapi")]
6mod bindings;
7mod broker;
8mod convert;
9mod distribution;
10mod eos;
11mod error;
12#[cfg(feature = "testing")]
13mod in_process;
14mod message;
15mod properties;
16mod publisher;
17mod record;
18mod redelivery;
19mod seek;
20mod startup;
21mod subscriber;
22mod subscription;
23#[cfg(feature = "testing")]
24mod testable;
25mod tracker;
26
27#[cfg(feature = "avro")]
28pub mod avro;
29pub mod context;
30pub mod prelude;
31#[cfg(feature = "protobuf")]
32pub mod protobuf;
33#[cfg(feature = "schema-registry")]
34pub mod schema_registry;
35
36pub use broker::{ClosedKafkaBroker, ConnectedKafkaBroker, KafkaBroker};
37pub use distribution::RoundRobin;
38pub use eos::{EOS_SOURCE_HEADER, EosPipeline, EosReplies, KafkaEosPublish, SourceOffset};
39pub use error::KafkaError;
40pub use message::{KafkaMessage, PARTITION_KEY_HEADER};
41#[cfg(feature = "protobuf")]
42pub use protobuf::{KafkaFramedPublish, KafkaFramedPublisher, ProtobufFrame};
43pub use publisher::{
44    KafkaOptions, KafkaPartitionedPublish, KafkaPublish, KafkaPublishSteps, KafkaPublisher,
45    KafkaTransactionalPublish, KafkaTransactionalPublisher, PartitionLanes,
46    TransactionalPartitions,
47};
48pub use redelivery::ToSourceTopic;
49#[cfg(feature = "schema-registry")]
50pub use schema_registry::{
51    HttpRegistryClient, MemorySchemaCache, MissingSubject, RegisteredSchema, RegistryClient,
52    SchemaCache, SchemaCachePolicy, SchemaFrame, SchemaFramed, SchemaPrefetch, SchemaRegistry,
53    SchemaType, SubjectStrategy,
54};
55pub use seek::{KafkaPosition, KafkaSeeker};
56
57pub use subscriber::KafkaSubscriber;
58pub use subscription::{
59    Assignment, Commit, KafkaPartitions, KafkaTopic, KafkaTopics, LaneKey, StartOffset,
60};
ruststream_rdkafka/lib.rs

ruststream_rdkafka/
lib.rs
