kacrab 0.1.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

//! Runtime Kafka wire/session support.

mod auth;
mod backoff;
mod broker;
mod buffer;
mod capabilities;
mod client;
mod config;
mod error;
#[cfg(feature = "gssapi")]
mod gssapi;
#[cfg(feature = "gssapi")]
mod kerberos;
mod message;
mod metadata;
mod pipeline;
mod sasl;
mod socket;
mod tls;

#[cfg(feature = "producer")]
pub(crate) use self::backoff::{BackoffPolicy, BackoffState};
#[cfg(feature = "producer")]
pub(crate) use self::broker::PendingBrokerResponse;
#[cfg(feature = "gssapi")]
pub use self::gssapi::GssapiAuthenticator;
#[cfg(feature = "producer")]
pub(crate) use self::metadata::PartitionLeaderChange;
pub use self::{
    auth::{SaslConfig, SaslMechanism, SecurityConfig, SecurityProtocol},
    broker::BrokerEndpoint,
    buffer::BufferPoolStats,
    capabilities::BrokerCapabilities,
    client::WireClient,
    config::{
        ConnectionConfig, DEFAULT_BROKER_QUEUE_CAPACITY, DEFAULT_BUFFER_POOL_CAPACITY,
        DEFAULT_MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, DEFAULT_METADATA_MAX_AGE,
        DEFAULT_METADATA_MAX_IDLE, DEFAULT_METADATA_REBOOTSTRAP_TRIGGER,
        DEFAULT_METADATA_REFRESH_BACKOFF_INITIAL, DEFAULT_METADATA_REFRESH_BACKOFF_MAX,
        DEFAULT_RECONNECT_BACKOFF_INITIAL, DEFAULT_RECONNECT_BACKOFF_MAX, DEFAULT_REQUEST_TIMEOUT,
        DEFAULT_REUSE_ADDRESS, DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT,
        DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT_MAX, DEFAULT_TCP_NODELAY, MetadataRecoveryStrategy,
        SocketConfig, TcpCongestionControl, TcpKeepaliveConfig, TransportConfig,
    },
    error::{Result, WireError},
    message::{RequestMessage, ResponseMessage},
    metadata::{BrokerMetadata, ClusterMetadata, PartitionMetadata, TopicMetadata},
    sasl::{
        SaslClientAction, SaslClientAuthenticator, SaslClientAuthenticatorFactory,
        SaslClientAuthenticatorFactoryHandle, SaslClientAuthenticatorHandle, SaslClientSession,
    },
    tls::TlsConfig,
};