# datum-mq
`datum-mq` is the Kafka satellite crate for Datum. It provides `KafkaSource`
and `KafkaSink` on top of `rdkafka`/`librdkafka`, with at-least-once source
offset commits and producer delivery confirmation.
The crate itself uses `#![forbid(unsafe_code)]`, but `rdkafka` is an FFI wrapper
around `librdkafka` and the native client owns its own polling threads and
queues. This connector is intentionally not marketed as a pure Tokio carrier.
Transactions and Kafka EOS are deferred. The first stable guarantee is
at-least-once: commit consumed offsets only after downstream work has completed,
and acknowledge produced records only after Kafka delivery confirmation.