cloudevents_sdk_rdkafka/
lib.rs

1//! This library provides Kafka protocol bindings for CloudEvents
2//! using the [rust-rdkafka](https://fede1024.github.io/rust-rdkafka) library.
3//!
4//! To produce Cloudevents:
5//!
6//! ```
7//!
8//! use cloudevents::Event;
9//! use rdkafka::producer::{FutureProducer, FutureRecord};
10//! use rdkafka::util::Timeout;
11//! use cloudevents_sdk_rdkafka::{MessageRecord, FutureRecordExt};
12//!
13//! # async fn produce(producer: &FutureProducer, event: Event) -> Result<(), Box<dyn std::error::Error>> {
14//! let message_record = MessageRecord::from_event(event)?;
15//!
16//! producer.send(
17//!     FutureRecord::to("topic")
18//!         .key("some_event")
19//!         .message_record(&message_record),
20//!     Timeout::Never
21//! ).await;
22//! # Ok(())
23//! # }
24//!
25//! ```
26//!
27//! To consume Cloudevents:
28//!
29//! ```
30//! use rdkafka::consumer::{StreamConsumer, DefaultConsumerContext, Consumer, CommitMode};
31//! use cloudevents_sdk_rdkafka::MessageExt;
32//! use futures::StreamExt;
33//!
34//! # async fn consume(consumer: StreamConsumer<DefaultConsumerContext>) -> Result<(), Box<dyn std::error::Error>> {
35//! let mut message_stream = consumer.start();
36//!
37//! while let Some(message) = message_stream.next().await {
38//!     match message {
39//!         Err(e) => println!("Kafka error: {}", e),
40//!         Ok(m) => {
41//!             let event = m.to_event()?;
42//!             println!("Received Event: {}", event);
43//!             consumer.commit_message(&m, CommitMode::Async)?;
44//!         }
45//!     };
46//! }
47//! # Ok(())
48//! # }
49//! ```
50
51#![doc(html_root_url = "https://docs.rs/cloudevents-sdk-rdkafka/0.3.1")]
52#![deny(broken_intra_doc_links)]
53
54#[macro_use]
55mod headers;
56mod kafka_consumer_record;
57mod kafka_producer_record;
58
59pub use kafka_consumer_record::record_to_event;
60pub use kafka_consumer_record::ConsumerRecordDeserializer;
61pub use kafka_consumer_record::MessageExt;
62
63pub use kafka_producer_record::BaseRecordExt;
64pub use kafka_producer_record::FutureRecordExt;
65pub use kafka_producer_record::MessageRecord;
cloudevents_sdk_rdkafka/lib.rs

cloudevents_sdk_rdkafka/
lib.rs
