Crate faucet_sink_kafka 

faucet-sink-kafka

Apache Kafka producer sink for faucet-stream. Publishes records to one or more Kafka topics with idempotent producer support, configurable compression, multi-topic routing, and QueueFull retry.

Re-exports

pub use config::Acks;

pub use config::KafkaSinkConfig;

pub use config::KafkaSinkTopic;

pub use sink::KafkaSink;

Modules

config

Configuration for the Kafka sink.

encode

Encode Kafka message bytes from a serde_json::Value, dispatching on KafkaValueFormat.

extract

Extract key / partition / topic / headers from records via JSONPath.

sink

KafkaSink: the producer implementation.

Structs

BasicAuth

Basic username/password credentials reused across auth modes.

SchemaRegistryConfigschema-registry

Confluent Schema Registry connection settings.

Enums

CompressionType

Producer-side compression for outbound batches.

FaucetError

All possible errors returned by faucet-stream.

KafkaAuth

Kafka broker authentication configuration.

KafkaValueFormat

How a Kafka message value (or key) is encoded on the wire.

OnDecodeError

What the source does when a single message fails to decode.

OnKeyError

What the sink does when key/partition extraction fails for a record.

ScramMechanism

SCRAM hash algorithm used for SASL/SCRAM authentication.

Constants

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.

Traits

Sink

A sink writes records to an external system.