ruststream-rdkafka 0.7.1

Apache Kafka broker implementation for the RustStream messaging framework, backed by rdkafka / librdkafka.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

#![doc = include_str!("README.md")]
#![forbid(unsafe_code)]

mod attention;
#[cfg(feature = "asyncapi")]
mod bindings;
mod broker;
mod convert;
mod distribution;
mod eos;
mod error;
#[cfg(feature = "testing")]
mod in_process;
mod message;
mod properties;
mod publisher;
mod record;
mod redelivery;
mod seek;
mod startup;
mod subscriber;
mod subscription;
#[cfg(feature = "testing")]
mod testable;
mod tracker;

#[cfg(feature = "avro")]
pub mod avro;
pub mod context;
pub mod prelude;
#[cfg(feature = "protobuf")]
pub mod protobuf;
#[cfg(feature = "schema-registry")]
pub mod schema_registry;

pub use broker::{ClosedKafkaBroker, ConnectedKafkaBroker, KafkaBroker};
pub use distribution::RoundRobin;
pub use eos::{EOS_SOURCE_HEADER, EosPipeline, EosReplies, KafkaEosPublish, SourceOffset};
pub use error::KafkaError;
pub use message::{KafkaMessage, PARTITION_KEY_HEADER};
#[cfg(feature = "protobuf")]
pub use protobuf::{KafkaFramedPublish, KafkaFramedPublisher, ProtobufFrame};
pub use publisher::{
    KafkaOptions, KafkaPartitionedPublish, KafkaPublish, KafkaPublishSteps, KafkaPublisher,
    KafkaTransactionalPublish, KafkaTransactionalPublisher, PartitionLanes,
    TransactionalPartitions,
};
pub use redelivery::ToSourceTopic;
#[cfg(feature = "schema-registry")]
pub use schema_registry::{
    HttpRegistryClient, MemorySchemaCache, MissingSubject, RegisteredSchema, RegistryClient,
    SchemaCache, SchemaCachePolicy, SchemaFrame, SchemaFramed, SchemaPrefetch, SchemaRegistry,
    SchemaType, SubjectStrategy,
};
pub use seek::{KafkaPosition, KafkaSeeker};

pub use subscriber::KafkaSubscriber;
pub use subscription::{
    Assignment, Commit, KafkaPartitions, KafkaTopic, KafkaTopics, LaneKey, StartOffset,
};