faucet_source_kafka/
lib.rs

1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-source-kafka
4//!
5//! Apache Kafka consumer source for `faucet-stream`. Subscribes to one or
6//! more topics, drains messages until `max_messages` or `idle_timeout`, and
7//! yields each message as a JSON object with key/value/topic/partition/
8//! offset/timestamp/headers fields.
9
10pub mod config;
11pub(crate) mod context;
12pub mod decode;
13pub mod shard;
14pub mod state;
15pub mod stream;
16
17#[cfg(feature = "schema-registry")]
18pub use faucet_common_kafka::SchemaRegistryConfig;
19pub use faucet_common_kafka::{
20    BasicAuth, CompressionType, KafkaAuth, KafkaValueFormat, OnDecodeError, OnKeyError,
21    ScramMechanism,
22};
23pub use faucet_core::{FaucetError, Source};
24
25pub use config::{KafkaSourceConfig, OffsetReset};
26pub use stream::KafkaSource;
faucet_source_kafka/lib.rs

faucet_source_kafka/
lib.rs
