flowly_kafka/lib.rs
1pub mod builder;
2pub mod config;
3pub mod consumer;
4pub mod error;
5pub mod message;
6pub mod producer;
7
8pub use message::{KafkaMessage, Message};
9
10struct KafkaCallbackContext(());
11
12impl rdkafka::ClientContext for KafkaCallbackContext {
13 fn error(&self, error: rdkafka::error::KafkaError, reason: &str) {
14 log::error!("Kafka global error occured: {error}, reason: {reason}. Restarting app.");
15 }
16}
17
18impl rdkafka::consumer::ConsumerContext for KafkaCallbackContext {}