kacrab 0.2.0

A Kafka client for Rust, built from the protocol up.
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! Producer API built on top of the wire/session layer.

mod accumulator;
mod api;
mod batch;
mod client;
mod compression_ratio;
mod config;
mod dispatcher;
mod error;
mod interceptor;
mod metrics;
mod partitioner;
mod record;
mod response;
mod routing;
mod sender;
mod serializer;
mod transaction;

pub(crate) use self::{
    accumulator::{AccumulatorConfig, ReadyBatch},
    config::ProducerRuntimeConfig,
};
#[cfg(test)]
pub(crate) use self::{
    accumulator::{RecordAccumulator, SharedAccumulator},
    config::ProducerIdempotenceConfig,
    transaction::{ProducerBatchState, ProducerIdentity},
};
pub use self::{
    api::{
        ConsumerGroupMetadata, OffsetAndMetadata, PartitionInfo, ProducerMetricSubscription,
        ProducerPartitionInfo, TopicPartition,
    },
    client::{Producer, ProducerBuilder},
    config::ProducerCompression,
    error::{ProducerError, Result},
    interceptor::ProducerInterceptor,
    metrics::{
        KafkaMetric, MetricConfig, MetricName, MetricNameTemplate, MetricQuota, MetricReporter,
        MetricValue, Metrics, MetricsError, ProducerMetricValue, ProducerMetricsSnapshot, SensorId,
        SensorRecordingLevel,
    },
    partitioner::{ProducerPartitioner, RoundRobinPartitioner},
    record::{
        DeliveryCallback, Header, Headers, ProducerRecord, RecordHeader, RecordHeaders,
        RecordMetadata, SendFuture,
    },
    sender::SYNC_NOW_BUFFER_SPINS,
    serializer::{
        BooleanSerializer, ByteArraySerializer, BytesSerializer, ConfiguredProducerSerializer,
        DoubleSerializer, FloatSerializer, IntegerSerializer, ListInnerSerializer,
        ListSerializationStrategy, ListSerializer, LongSerializer, ProducerSerializer,
        ShortSerializer, StringSerializer, TypedProducer, UuidSerializer, VoidSerializer,
    },
};

/// Implementation details exposed for repository benchmarks and integration tests.
///
/// This module is not part of the stable user-facing producer API.
#[doc(hidden)]
pub mod internals {
    pub use super::{
        accumulator::{AccumulatorConfig, ReadyBatch, RecordAccumulator, SharedAccumulator},
        config::{ProducerIdempotenceConfig, ProducerRuntimeConfig},
        dispatcher::ProducerDispatcher,
        transaction::{ProducerBatchState, ProducerIdentity},
    };
}