datum-mq 0.10.3

Kafka sources and sinks for Datum streams, backed by rdkafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

#![allow(dead_code)]

//! Datum-native Kafka consumer engine.
//!
//! This module is private to `datum-mq`; users select it through
//! `KafkaConsumerSettings::with_consumer_backend(KafkaConsumerBackend::Native)`.
//! `KafkaSink` and unsupported Kafka features remain on the `rdkafka` path.

mod client;
mod connection;
mod error;
mod model;
pub(crate) mod profile;
pub(crate) mod protocol;
mod source;

pub(crate) use client::{
    AutoOffsetReset, FetchTuning, GroupAssignor, NativeCommitPolicy, NativeKafkaConsumerConfig,
};
pub(crate) use error::{KafkaClientError, KafkaClientResult};
pub(crate) use model::{KafkaPayloadBatch, KafkaTimestamp, StartOffset, TopicPartitionAssignment};
pub(crate) use source::{NativeKafkaControl, NativeKafkaSource};

pub(crate) const VERSION: &str = env!("CARGO_PKG_VERSION");

#[cfg(test)]
pub(crate) use client::NativeKafkaConsumer;
#[cfg(test)]
pub(crate) use model::TopicPartition;
#[cfg(test)]
mod tests;