Skip to main content

faucet_sink_kafka/
lib.rs

1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-sink-kafka
4//!
5//! Apache Kafka producer sink for `faucet-stream`. Publishes records to one
6//! or more Kafka topics with idempotent producer support, configurable
7//! compression, multi-topic routing, and QueueFull retry.
8
9pub mod config;
10pub mod encode;
11pub mod extract;
12mod idempotent;
13pub mod sink;
14
15#[cfg(feature = "schema-registry")]
16pub use faucet_common_kafka::SchemaRegistryConfig;
17pub use faucet_common_kafka::{
18    BasicAuth, CompressionType, KafkaAuth, KafkaValueFormat, OnDecodeError, OnKeyError,
19    ScramMechanism,
20};
21pub use faucet_core::{FaucetError, Sink};
22
23pub use config::{Acks, KafkaSinkConfig, KafkaSinkTopic};
24pub use sink::KafkaSink;
25
26mod descriptor;
27pub use descriptor::DESCRIPTOR;